Details
-
Improvement
-
Status: Open
-
P3
-
Resolution: Unresolved
-
None
-
None
-
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
-
BEAM-7310 Confluent Schema Registry support in KafkaIO
- Triage Needed