[
https://issues.apache.org/jira/browse/BEAM-9330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía updated BEAM-9330:
-------------------------------
Status: Open (was: Triage Needed)
> 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 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)
