| 来源 | binlog/redo log |
|---|---|
| 模式 | 全量+增量 |
| 落点 | 湖表/Kafka/OLAP |
| 难点 | schema 变更 |
CDC 入湖
CDC 入湖
CREATE TABLE mysql_orders (
order_id STRING,
pay_amt DECIMAL(18,2),
PRIMARY KEY (order_id) NOT ENFORCED
) WITH (
'connector' = 'mysql-cdc',
'hostname' = '10.0.0.10',
'port' = '3306',
'database-name' = 'trade',
'table-name' = 'orders'
);
INSERT INTO ods_mysql_orders SELECT * FROM mysql_orders;源表加字段后未同步目标表结构，同步任务会因 schema 不匹配中断。