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

Support namespaces provided in the Schema

    XMLWordPrintable

    Details

    • Type: Improvement
    • Status: Open
    • Priority: Unknown
    • Resolution: Unresolved
    • Affects Version/s: None
    • Fix Version/s: 1.7.0
    • Component/s: None
    • Labels:
    • Quarter:
    • Case:

      Description

      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.

        Attachments

          Activity

            People

            Assignee:
            Unassigned Unassigned
            Reporter:
            ross.lawley Ross Lawley
            Votes:
            0 Vote for this issue
            Watchers:
            5 Start watching this issue

              Dates

              Created:
              Updated: