FlinkCDC笔记

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