You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Zhenhao Li (JIRA)" <ji...@apache.org> on 2018/12/13 17:44:00 UTC

[jira] [Created] (FLINK-11160) Confluent Avro Serialization Schema

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)