Consistency of Replicated Kafka Cluster and ways to test

/ test for lost messages? kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --group KafkaMirror --zkconnect source-cluster-zookeeper:2181 --topic test-topic I can understand that that is the only way we can check the mirroring? Best Regards, -- Kamen Tarlov

Re: Consistency of Replicated Kafka Cluster and ways to test

/ test for lost messages? kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --group KafkaMirror --zkconnect source-cluster-zookeeper:2181 --topic test-topic I can understand that that is the only way we can check the mirroring? Best Regards, -- Kamen Tarlov