Uploaded image for project: 'Kafka Connector'
  1. Kafka Connector
  2. KAFKA-246

Support namespaces provided in the Schema

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

      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.kovalenko@mongodb.com Valentin Kavalenka
            Reporter:
            ross@mongodb.com Ross Lawley
            Votes:
            0 Vote for this issue
            Watchers:
            5 Start watching this issue

              Created:
              Updated:
              Resolved: