[
https://issues.apache.org/jira/browse/BEAM-9330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17043199#comment-17043199
]
Ismaël Mejía commented on BEAM-9330:
------------------------------------
Notice that this one can be addressed only when CSR 6 is released, probably
worth to check if users can use the CSR 6 client with a CSR 5 server too.
> 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
> Assignee: Ismaël Mejía
> Priority: Minor
>
> 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.3.4#803005)
