We took the default schema from the source connector documentation under output.schema.value and modified it as following:
- Adding namespace
- Renaming ChangeStream to MongoSourceChangeEvent
We use the schema above in output.schema.value. When the schema is registered by the connector in the schema registry - the namespace field is not included.
This creates a problem for us in Kotlin, where we can’t include namespace in the import because deserialization will fail, instead of:
We are forced to remove the namespace from the schema and import it without namespace (the schema being registered is also being used to auto generate Avro classes) :
We want to have a proper namespace for our auto generated classes and currently this issue prevents us from doing so.