Hi All, I'd like to initiate a vote for KIP-971. This KIP is about adding a new metric to the MirrorSourceTask that tracks the offset lag between a source and a target partition.
KIP link: https://cwiki.apache.org/confluence/display/KAFKA/KIP-971%3A+Expose+replication-offset-lag+MirrorMaker2+metric Discussion thread: https://lists.apache.org/thread/gwq9jd75dnm8htmpqkn17bnks6h3wqwp Thanks!