I’m trying to make MongoDB Source Connector 1.5 with Avro and Schema Registry. I’m facing the following issues (in all cases output.schema.value
is provided):
- when
auto.register.schemas
istrue
, the created schema is identical to the one provided in the connector creation request, but it’s missing namespace fields, even thoughenhanced.avro.schema.support
is set totrue
. - when
auto.register.schemas
isfalse
,use.latest.version
istrue
,latest.compatible.strict
isfalse
, and the schema is registered in the schema registry externally, I getUnresolvedUnionException: Not in union
, even though the same schema is used as in the scenario above. - when
auto.register.schemas
isfalse
anduse.latest.version
isfalse
, I getSchema not found; error code: 40403
How should I configure the source connector to be able to provide a schema externally (i.e. not infer and not auto register), and preserve the namespace information in schema registry?
Also, serialization failures do not result in sending failed records to the dead letter queue. Is this an expected behavior?