irpas技术客

Flink CDC 系列(5)—— Flink CDC MySQL Connector 启动模式_白月蓝山

大大的周 7830

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 系列(7)—— 从 MySQL 到 ElasticSearch》

文章目录 简介initiallatest-offset使用场景

简介

Flink CDC MySQL Connector 可通过参数 scan.startup.mode 配置启动模式。 启动模式有两种:initial 和 latest-offset

initial

initial: 在首次启动时,对数据库的表执行初始快照,快照数据读取完成后继续读取 binlog 数据。这个模式可以得到历史到现在的所有数据。initial 是默认的启动模式。

latest-offset

latest-offset: 首次启动时不执行快照,只读取 binlog 的最新数据。

使用场景

如果需要读取全量的数据,包括历史数据和 binlog 数据则选用 initial 模式。 如果只需要最新的 binlog 数据,则选用 latest-offset。


1.本站遵循行业规范,任何转载的稿件都会明确标注作者和来源;2.本站的原创文章,会注明原创字样,如未注明都非原创,如有侵权请联系删除!;3.作者投稿可能会经我们编辑修改或补充;4.本站不提供任何储存功能只提供收集或者投稿人的网盘链接。

标签: #Flink #CDC #系列5 #MySQL #Connector #启动模式