FlinkCDC笔记

q1: 有什么方式判定mysql的快照读阶段是否完成呢?
a: currentEmitEventTimeLag 指标记录的是 Source 发送一条记录到下游节点的时间点和该记录在 DB 里产生时间点差值,用于衡量数据从 DB 产生到离开 Source 节点的延迟。用户可以通过该指标判断 source 是否进入了 binlog 读取阶段:
即当该指标为 0 时,代表还在全量历史读取阶段;
当大于 0 时,则代表进入了 binlog 读取阶段。
参考FLIP-33: Standardize Connector Metrics

Powered By Valine
v1.5.2