Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-9330

Add support for Protobuf and JSON Schema on KafkaIO + Confluent Schema Registry

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Open
    • P3
    • Resolution: Unresolved
    • None
    • None
    • io-java-kafka
    • None

    Description

      Confluent Schema Registry (CSR) 6 introduces support for other Schema types like Protobuf and JSON Schema. We should adapt KafkaIO to obtain the type of Schema and configure correctly its Deserializer and Coder.

      Protobuf support
      https://github.com/confluentinc/schema-registry/pull/1285
      JSON Schema support
      https://github.com/confluentinc/schema-registry/pull/1289

       

      Attachments

        Issue Links

          is related to

          Improvement - An improvement or enhancement to an existing feature or task. BEAM-7310 Confluent Schema Registry support in KafkaIO

          • P3 - Non-urgent bugs, features, and improvements
          • Triage Needed

          Activity

            People

              Unassigned Unassigned
              iemejia Ismaël Mejía
              Votes:
              0 Vote for this issue
              Watchers:
              6 Start watching this issue

              Dates

                Created:
                Updated: