[FLINK-10017] Support keyed formats for Kafka table source sink factory

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Implemented
• Component/s: Table SQL / API
• Labels: auto-unassigned
• Assignee: Unassigned
• Reporter: Timo Walther
• Created: 01/Aug/18 14:21
• Updated: 30/Apr/21 02:57
• Resolved: 30/Apr/21 02:57

Description

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