Re: Kafka - offset preservation

2016-07-10 Thread R Krishna
Which version is this? I am a new user myself, are you using the same consumer group name? In V0.9, once connected, broker stores consumer offsets per consumer group, and continues from where it left off, the earliest/latest are for the first time only. On Wed, Jul 6, 2016 at 6:19 AM, Pawel Huszcz

Kafka - offset preservation

2016-07-06 Thread Pawel Huszcza
Hello, I tried every different property I can think of - I have set ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG = true; ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG = 1000, but I have also tried with many different values And still every time I start my consumer - I am receiving all the messages