Using MirrorMaker2 | How to conclude that clusters are in sync?

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

Re: Is the KafkaStreams#store() method thread-safe?

You need to wrap Hashmap with ConcurrentHashMap imlementation otherwise you will receive no Thread Notifications Sent from my Verizon, Samsung Galaxy smartphone Get Outlook for Android From: Kohei Nozaki Sent: Wednesday, December 27, 2023