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

[hudeqi]

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; 发件人: "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>