You can use the seekToBeginning method of KafkaConsumer. https://kafka.apache.org/0100/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#seekToBeginning(java.util.Collection)
On Thu, Feb 9, 2017 at 7:56 PM, Igor Kuzmenko <f1she...@gmail.com> wrote: > Hello, I'm using new consumer to read kafka topic. For testing, I want to > read the same topic from the beggining multiple times, with same consumer. > Before restarting test, I want to delete consumer offsets, so consumer > start read from begining. Where can I find offsets? >
