Details
-
New Feature
-
Status: Open
-
Minor
-
Resolution: Unresolved
-
1.19.0, 1.18.1
-
None
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