The article explores the ingestion of Debezium change events from Kafka into Apache Flink using Flink SQL. It details the use of two main connectors—the Apache Kafka SQL Connector and the Upsert Kafka SQL Connector—highlighting their functionalities in both append-only and changelog modes, along with key configurations and considerations for processing Debezium data effectively.
flink ✓
+ kafka
debezium ✓
sql ✓
changelog ✓