How about High watermark check ? Since consumers consume based on HWM, presence of the same HWM should be a good checkpoint, no?
Regards, On Mon, 4 Nov 2019 at 22:53, Guillaume Arnaud <[email protected]> wrote: > Hi, > > I would like to compare the messages of an original topic with a mirrored > topic in an other cluster to be sure that the content is the same. > > I see that checksum method in KafkaConsumer is deprecated: > > https://kafka.apache.org/10/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html > > What is the best way to do that ? > > Thank you, > > Guillaume >
