[FLINK-23639] Migrate Table API to new KafkaSink

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.14.0
• Component/s: Connectors / Kafka, Table SQL / API
• Labels: pull-request-available

Release Note

Table API/SQL write to Kafka with the new `KafkaSink`. When migrating from a query writing to Kafka in exactly-once mode from an earlier Flink version, make sure to terminate the old application with stop-with-savepoint to avoid lingering Kafka transactions. To run in exactly-once processing mode, the sink needs a user-configured and unique transaction prefix, such that transactions of different applications do not interfere with each other.

• Assignee: Fabian Paul
• Reporter: Fabian Paul
• Created: 05/Aug/21 08:54
• Updated: 10/Sep/21 13:29
• Resolved: 13/Aug/21 16:06

Description

With the KafkaSink ported to FLIP-143 we should also adapt the Table API to leverage the new KafkaSink

Issue Links

• links to: GitHub Pull Request #16769