Hi, I am using MirrorMaker2 to do unidirectional mirroring of all topics from one Kafka cluster to other. I am doing this to migrate clusters to reduce storage size.
I am looking for a way to conclude the exercise and ensure that the clusters are synched and start migrating consumers to the target cluster. Please help me with metrics or validation step to conclude that the clusters are in sync and all messages of a particular topic are migrated to the target cluster. Thanks Akshaya