[
https://issues.apache.org/jira/browse/FLINK-11160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-11160:
-------------------------------
Labels: pull-request-available scala starter (was: newbie
pull-request-available scala)
> Confluent Avro Serialization Schema
> ------------------------------------
>
> Key: FLINK-11160
> URL: https://issues.apache.org/jira/browse/FLINK-11160
> Project: Flink
> Issue Type: Improvement
> Components: Connectors / Kafka
> Affects Versions: 1.7.0
> Reporter: Zhenhao Li
> Priority: Minor
> Labels: pull-request-available, scala, starter
> 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
(v8.20.10#820010)
