[
https://issues.apache.org/jira/browse/FLINK-11160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16721067#comment-16721067
]
Dawid Wysakowicz commented on FLINK-11160:
------------------------------------------
Hi [~Zhen-hao],
Welcome to the Flink community and thank you very much you want to contribute
to the Flink project. There is some already ongoing effort of introducing
serialization schema that works with confluent schema registry that approaches
this problem in a more general way. Therefore I am afraid we won't be able to
merge your code. If you still want to contribute something, maybe you would
like to pick up the effort in [FLINK-9679] as it is stale for some time.
> 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
> Priority: Minor
> Labels: newbie, pull-request-available, scala
> Fix For: 1.7.2, 1.8.0
>
> Original Estimate: 24h
> Time Spent: 10m
> Remaining Estimate: 23h 50m
>
> 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)
