0%

FlinkCDC原理

本文主要包括:

  • FlinkCDC概述

FlinkCDC概述

支持 currentFetchEventTimeLag,currentEmitEventTimeLag,sourceIdleTime 监控指标
这些指标遵循 FLIP-33 [1] 的连接器指标规范,可以查看 FLIP-33 获取每个指标的含义。其中,
currentEmitEventTimeLag 指标记录的是 Source 发送一条记录到下游节点的时间点和该记录
在 DB 里产生时间点差值,用于衡量数据从 DB 产生到离开 Source 节点的延迟。用户可以通
过该指标判断 source 是否进入了 binlog 读取阶段:

  • 即当该指标为 0 时,代表还在全量历史读取阶段;
  • 当大于 0 时,则代表进入了 binlog 读取阶段。