Zhenhao Li created FLINK-11160:
----------------------------------
Summary: Confluent Avro Serialization Schema
Key: FLINK-11160
URL: https://issues.apache.org/jira/browse/FLINK-11160
Project: Flink
Issue Type: Improvement
Components: Kafka Connector
Affects Versions: 1.7.0
Reporter: Zhenhao Li
Fix For: 1.8.0, 1.7.2
Currently, Flink is missing Serialization Schema to work with the Confluent
Avro format and the Confluent schema registry.
I wrote something that solved this problem for the company I currently work at.
I think it is nice to contribute something back to the community. It has been
used in a Scala project, and the project has been deployed to production.
The new serialization schemas only serialize GenericRecord and users have to
pass the Avro schema files to the constructors. It might be not flexible enough
to cover a broader set of use cases. The keyed serialization schema works for
only Scala key-value paris.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
