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

Support auto generated schema structs

    • Type: Icon: Improvement Improvement
    • Resolution: Fixed
    • Priority: Icon: Major - P3 Major - P3
    • 1.3.0
    • Affects Version/s: None
    • Component/s: Source
    • None
    • Hide

      Added a new config:

      output.schema.infer.value=[false,true]

      An example use case is when publishing fulldocuments that have the same / similar shapes:

      publish.full.document.only=true
      output.json.formatter=com.mongodb.kafka.connect.source.json.formatter.SimplifiedJson
      output.format.value=schema
      output.schema.infer.value=true

      Note: A schema is inferred for each document outputted by the change stream. So each document could have its own schema definition. For Bson types that are not supported by Kafka eg: minValue, ObjectId a string value will be produced using the output json formatter.

      Show
      Added a new config: output.schema.infer.value= [false,true] An example use case is when publishing fulldocuments that have the same / similar shapes: publish.full.document.only=true output.json.formatter=com.mongodb.kafka.connect.source.json.formatter.SimplifiedJson output.format.value=schema output.schema.infer.value=true Note: A schema is inferred for each document outputted by the change stream. So each document could have its own schema definition. For Bson types that are not supported by Kafka eg: minValue, ObjectId a string value will be produced using the output json formatter.

          Assignee:
          ross@mongodb.com Ross Lawley
          Reporter:
          ross@mongodb.com Ross Lawley
          Votes:
          0 Vote for this issue
          Watchers:
          1 Start watching this issue

            Created:
            Updated:
            Resolved: