[
https://issues.apache.org/jira/browse/BEAM-9330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17548390#comment-17548390
]
Danny McCormick commented on BEAM-9330:
---------------------------------------
This issue has been migrated to https://github.com/apache/beam/issues/20032
> Add support for Protobuf and JSON Schema on KafkaIO + Confluent Schema
> Registry
> -------------------------------------------------------------------------------
>
> Key: BEAM-9330
> URL: https://issues.apache.org/jira/browse/BEAM-9330
> Project: Beam
> Issue Type: Improvement
> Components: io-java-kafka
> Reporter: Ismaël Mejía
> Priority: P3
>
> 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]
>
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
