欢迎您访问365答案网,请分享给你的朋友!
生活常识 学习资料

FlinkCDC系列(5)——FlinkCDCMySQLConnector启动模式

时间:2023-04-20

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

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

latest-offset

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

使用场景

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

Copyright © 2016-2020 www.365daan.com All Rights Reserved. 365答案网 版权所有 备案号:

部分内容来自互联网,版权归原作者所有,如有冒犯请联系我们,我们将在三个工作时内妥善处理。