Re: consumer reread messages

2016-08-30 Thread Michael Freeman
You can you seek. https://kafka.apache.org/090/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#seek(org.apache.kafka.common.TopicPartition,%20long) Or if you want to re read the entire log use a different consumer group name and use auto.offset.reset=earliest On Tue, Aug 30, 2016

consumer reread messages

2016-08-29 Thread Fahimeh Ashrafy
Hello all how is it possible to set the consumer reread logs? I think I have to return offset back of the current offset? Thanks a lot