flink-cdc
flink-cdc copied to clipboard
[FLINK-35245][cdc-connector][tidb] Add metrics for flink-connector-tidb-cdc
https://issues.apache.org/jira/browse/FLINK-35245
add metrcis: currentFetchEventTimeLag, currentEmitEventTimeLag, sourceIdleTime for TiKVRichParallelSourceFunction