Hi Elkhan, I think this is quite a useful improvement. A few questions, suggestions: 1. How do you calculate the min, max and avg variants? If I understand correctly then the metric itself is partition based (where replication-offset-lag is the lag of the replica that is being consumed) and these are min, max, avg across replicas? 2. You briefly mention replication-latency-ms at the end but I think it'd be worth writing a bit more about it, what it does currently, how it is calculated and therefore why it doesn't fit.
Thanks, Viktor On Sat, Aug 26, 2023 at 3:49 PM Elxan Eminov <elxanemino...@gmail.com> wrote: > Relatively minor change with a new metric for MM2 > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-971%3A+Expose+replication-offset-lag+MirrorMaker2+metric >