| 定位 | Flink 生态的 CDC 连接器与整库同步工具 |
|---|---|
| 引擎 | 连接器底层基于 Debezium 引擎解析日志 |
| 关键能力 | 增量快照（无锁并发）、checkpoint 位点提交、整库同步 |
| 入口 | Flink SQL / DataStream API / YAML pipeline（3.x） |
SQL 声明 CDC 源表并直接加工
SQL 声明 CDC 源表并直接加工
CREATE TABLE orders (order_id BIGINT, status STRING, PRIMARY KEY (order_id) NOT ENFORCED)
WITH ('connector' = 'mysql-cdc', 'hostname' = '10.0.0.5', 'database-name' = 'app', 'table-name' = 'orders');
SELECT status, COUNT(*) FROM orders GROUP BY status;CDC 源表是持续变更流：SELECT 是长跑作业，聚合要配合窗口或连续查询，不能当批表反复扫描。