[
https://issues.apache.org/jira/browse/KAFKA-14112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746108#comment-17746108
]
Elkhan Eminov commented on KAFKA-14112:
---------------------------------------
[~viktorsomogyi] I've created the PR, please take a look when you can :)
> Expose replication-offset-lag Mirror metric
> -------------------------------------------
>
> Key: KAFKA-14112
> URL: https://issues.apache.org/jira/browse/KAFKA-14112
> Project: Kafka
> Issue Type: Improvement
> Components: mirrormaker
> Reporter: Elkhan Eminov
> Assignee: Elkhan Eminov
> Priority: Minor
>
> The replication offset lag is the difference of the {*}l{*}ast {*}e{*}nd
> {*}o{*}ffset of the source partition (LEO) the {*}l{*}ast {*}r{*}eplicated
> _source_ {*}o{*}ffset (LRO), +1 (to account for zero-based offset numbering)
> The offset lag is a difference (LEO-LRO), and its constituents are calculated
> at different points of time and place:
> * LEO shall be calculated during source task's poll loop (ready to get it
> from the consumer)
> * LRO shall be kept in an in-memory "cache", that is updated during the
> task's producer callback
> The difference shall be calculated when the freshest LEO acquired in the poll
> loop. The calculated amount shall be defined as a MirrorMaker metric.
> This would describe to amount of "to be replicated" number of records for a
> certain topic-partition.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
