Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-34440

Support Debezium Protobuf Confluent Format

    XMLWordPrintableJSON

Details

    Description

      Motivation

      Debezium and the Confluent Schema registry can be used to emit Protobuf Encoded messages to Kafka, but Flink does not easily support consuming these messages through a connector.

      Definition of Done

      Add a format `debezium-protobuf-confluent` provided by DebeziumProtobufFormatFactory that supports Debezium messages encoded using Protocol Buffer and the Confluent Schema Registry. 

      To consider

      • Mirror the implementation of the `debezium-avro-confluent` format. First implement a `protobuf-confluent` format similar to the existing Confluent Avro format that's provided today, which allows reading/writing protobuf using the Confluent Schema Registry

      Attachments

        Activity

          People

            Unassigned Unassigned
            klam-shop Kevin Lam
            Votes:
            0 Vote for this issue
            Watchers:
            5 Start watching this issue

            Dates

              Created:
              Updated: