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 at 5:40 AM, Fahimeh Ashrafy <fahimehashr...@gmail.com> wrote: > 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 >
