[
https://issues.apache.org/jira/browse/FLINK-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-10017.
--------------------------------
Resolution: Implemented
Implemented in FLINK-19294
> Support keyed formats for Kafka table source sink factory
> ---------------------------------------------------------
>
> Key: FLINK-10017
> URL: https://issues.apache.org/jira/browse/FLINK-10017
> Project: Flink
> Issue Type: Sub-task
> Components: Table SQL / API
> Reporter: Timo Walther
> Priority: Major
> Labels: auto-unassigned
>
> Currently, the Kafka table source sink factory does not support keyed formats
> that would result in {{KeyedSerializationSchema}} and
> {{KeyedDeserializationSchema}}. It should be possible to define:
> - a key format
> - a value format
> - a target topic
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
