Support namespaces provided in the Schema

XMLWordPrintableJSON

    • Type: Improvement
    • Resolution: Fixed
    • Priority: Unknown
    • 1.7.0
    • Affects Version/s: None
    • Component/s: None
    • None
    • Needed
    • None
    • None
    • None
    • None
    • None
    • None

      See: https://www.mongodb.com/community/forums/t/kafka-source-connector-output-schema-value-not-registering-namespace/102645/2

      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:
      import com.company.common.avro.MongoSourceChangeEvent

      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) :
      import MongoSourceChangeEvent

      We want to have a proper namespace for our auto generated classes and currently this issue prevents us from doing so.

              Assignee:
              Valentin Kavalenka
              Reporter:
              Ross Lawley
              Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

                Created:
                Updated:
                Resolved: