[FLINK-19857] FLIP-149: Introduce the upsert-kafka Connector

• Type: New Feature
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.12.0
• Component/s: Connectors / Kafka, Table SQL / API, Table SQL / Ecosystem
• Assignee: Shengkai Fang
• Reporter: Jark Wu
• Created: 28/Oct/20 12:37
• Updated: 14/Jan/21 09:20
• Resolved: 07/Dec/20 04:06

Description

This is the umbrella issue for FLIP-149: Introduce the upsert-kafka Connector

FLIP-149: https://cwiki.apache.org/confluence/display/FLINK/FLIP-149%3A+Introduce+the+upsert-kafka+Connector

Issue Links

• contains: FLINK-8545 Implement upsert stream table source
• duplicates: FLINK-18826 Support to emit and encode upsert messages to Kafka
• duplicates: FLINK-19149 Compacted Kafka Topic can be interpreted as Changelog Stream
• mentioned in: Page Loading...
• mentioned in: Page Loading...

Sub-Tasks

• Support [UPDATE_AFTER, DELETE] ChangelogMode for ScanTableSource: Closed
• Add the new table factory for upsert-kafka connector: Closed
• Fix WatermarkAssigner shouldn't be after ChangelogNormalize: Closed
• Add documentation for the upsert-kafka connector: Closed
• Translate page 'upsert-kafka Connector' into Chinese: Closed