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