[ 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)