简介Flink CDC 系列文章:
《Flink CDC 系列(1)—— 什么是 Flink CDC》
《Flink CDC 系列(2)—— Flink CDC 源码编译》
《Flink CDC 系列(3)—— Flink CDC MySQL Connector 与 Flink SQL 的结合使用案例Demo》
《Flink CDC 系列(4)—— Flink CDC MySQL Connector 常用参数表》
《Flink CDC 系列(5)—— Flink CDC MySQL Connector 启动模式》
《Flink CDC 系列(6)—— Flink CDC MySQL Connector 工作机制之 Incremental Snapshot Reading》
Flink CDC MySQL Connector 可通过参数 scan.startup.mode 配置启动模式。
启动模式有两种:initial 和 latest-offset
initial: 在首次启动时,对数据库的表执行初始快照,快照数据读取完成后继续读取 binlog 数据。这个模式可以得到历史到现在的所有数据。initial 是默认的启动模式。
latest-offsetlatest-offset: 首次启动时不执行快照,只读取 binlog 的最新数据。
使用场景 如果需要读取全量的数据,包括历史数据和 binlog 数据则选用 initial 模式。
如果只需要最新的 binlog 数据,则选用 latest-offset。