[
https://issues.apache.org/jira/browse/FLINK-40397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
wangkang updated FLINK-40397:
-----------------------------
Attachment: (was: image-2026-08-16-16-27-55-610.png)
> Add binlog position lag metrics for MySQL binlog reader
> -------------------------------------------------------
>
> Key: FLINK-40397
> URL: https://issues.apache.org/jira/browse/FLINK-40397
> Project: Flink
> Issue Type: Improvement
> Components: Flink CDC
> Reporter: wangkang
> Priority: Major
> Labels: pull-request-available
>
> Add two new gauge metrics to measure how far behind the MySQL binlog reader
> is from the master:
>
>
>
>
> - currentBinlogTransactionLag: GTID-based transaction count lag (-1 when
> GTID is unavailable)
>
> - currentBinlogBytePositionLag: byte-level lag based on binlog file +
> position (-1 when position info is unavailable)
>
>
>
>
> Unlike currentFetchEventTimeLag (which only updates when events are
> flowing), these metrics reflect lag even during idle periods.
>
>
>
>
>
> The feature is opt-in via scan.binlog.position-lag.interval.ms (default -1
> = disabled). A positive value enables periodic SHOW MASTER STATUS polling at
> the specified interval.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
