[jira] [Comment Edited] (BEAM-9330) Add support for Protobuf and JSON Schema on KafkaIO + Confluent Schema Registry

["Ismaël Mejía (Jira)" <ji...@apache.org>]

    [ 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 edited comment on BEAM-9330 at 4/26/20, 8:55 PM:
--------------------------------------------------------------

Notice that this one can be addressed now that CSR 5.5 is released, probably worth to check if users can use the CSR 5.5 client library with previous versions of the CSR server without issues.

https://www.confluent.io/blog/introducing-confluent-platform-5-5/



was (Author: iemejia):
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)