Auto Commit is to sync offset to zookeeper periodically. Without auto
commit, consumer still maintains an offset locally. It explains this
behavior.
To be able to rewind, you need to use SimpleConsumer.
2014/11/15 上午2:18 於 "dinesh kumar" 寫道:
> Hi,
> I am trying to understand the behavior of Kafk
Hi,
I am trying to understand the behavior of Kafka Consumer in Java.
Consider a scenario where a consumer is reading from a partition with
auto.comiit disabled and only one partition in the topic. The consumer
reads a message 'A' and sleep for some time, say 10 seconds. Then reads
from the same p