Re: Consumer reading from same topic twice without commiting

2014-11-14 Thread Chia-Chun Shih
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

Consumer reading from same topic twice without commiting

2014-11-14 Thread dinesh kumar
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