You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Alexey Romanenko (Jira)" <ji...@apache.org> on 2021/01/12 14:56:00 UTC
[jira] [Commented] (BEAM-9330) Add support for Protobuf and JSON
Schema on KafkaIO + Confluent Schema Registry
[ https://issues.apache.org/jira/browse/BEAM-9330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17263390#comment-17263390 ]
Alexey Romanenko commented on BEAM-9330:
----------------------------------------
Is it blocked by Avro update (BEAM-8388)?
> 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.3.4#803005)