CDC与Flink：数据库变更实时同步

📋 面试题

什么是CDC？Flink CDC是怎么工作的？你们用CDC做什么？

CDC是什么？

Change Data Capture：捕获数据库的增删改变更，实时同步到下游系统。

MySQL INSERT/UPDATE/DELETE
    ↓ Binlog
Flink CDC 捕获变更
    ↓
写入 Kafka / Doris / Hudi / 数仓

传统方案是每天全量同步（T+1），CDC实现了秒级同步。

Flink CDC的核心优势：全增量一体

传统CDC方案（Debezium + Kafka）：
  全量快照 → Kafka → Flink消费
  增量Binlog → Kafka → Flink消费
  需要两套流程，切换复杂

Flink CDC（内置）：
  全量快照 + 增量Binlog → 一个Flink作业搞定
  自动从快照切换到增量，无缝衔接

-- Flink SQL直接读MySQL的CDC
CREATE TABLE mysql_orders (
    order_id INT,
    user_id STRING,
    amount DECIMAL(10,2),
    status STRING,
    update_time TIMESTAMP(3),
    PRIMARY KEY (order_id) NOT ENFORCED
) WITH (
    'connector' = 'mysql-cdc',
    'hostname' = 'mysql-host',
    'port' = '3306',
    'username' = 'flink',
    'password' = 'xxx',
    'database-name' = 'shop',
    'table-name' = 'orders'
);

-- 直接同步到Doris
INSERT INTO doris_orders SELECT * FROM mysql_orders;