Hi All I am a newbie to kafka. I am using the new Consumer API in a thread acting as a consumer for a topic in Kafka. For my testing and other purposes I have read the queue multiple times using console-consumer.sh script of kafka.
To start reading the message from the beginning in my java code , I have set the value of the auto.offset.reset to "earliest". However that property does not guarantee that i begin reading the messages from start, it goes by the most recent smallest offset for the consumer group. Here is my question, Is there a assured way of starting to read the messages from beginning from Java based Kafka Consumer ? Once I reset one of my consumers to zero, do i have to do offset management myself for other consumer threads or does kafka automatically lower the offset to the first threads read offset ? Any information / material pointing to the solution are highly appreciated. Thanks Pradeep
