Re: Re: [DISCUSS] KIP-971 Expose replication-offset-lag MirrorMaker2 metric

[Elxan Eminov]

I already have the PR for this so if it will make it easier to discuss,
feel free to take a look: https://github.com/apache/kafka/pull/14077

On Mon, 4 Sept 2023 at 09:17, hudeqi <16120...@bjtu.edu.cn> wrote:

> But does the offset of the last `ConsumerRecord` obtained in poll not only
> represent the offset of this record in the source cluster? It seems that it
> cannot represent the LEO of the source cluster for this partition. I
> understand that the offset lag introduced here should be the LEO of the
> source cluster minus the offset of the last record to be polled?
>
> best,
> hudeqi
>
>
> &gt; -----原始邮件-----
> &gt; 发件人: "Elxan Eminov" <elxanemino...@gmail.com>
> &gt; 发送时间: 2023-09-04 14:52:08 (星期一)
> &gt; 收件人: dev@kafka.apache.org
> &gt; 抄送:
> &gt; 主题: Re: [DISCUSS] KIP-971 Expose replication-offset-lag MirrorMaker2
> metric
> &gt;
> </elxanemino...@gmail.com>