Re: Manual offset commit losing a message?

2016-05-06 Thread Hemanth Yamijala
Sorry for the distraction. I think I had a typo in the property name: it is auto.commit.enable and not auto.commit.enabled (no 'd' at the end). It seems to be working as expected with the correction. Thanks hemanth On Fri, May 6, 2016 at 6:26 PM, Hemanth Yamijala wrote: >

Manual offset commit losing a message?

2016-05-06 Thread Hemanth Yamijala
Hi all, I am using Kafka 0.9.0.1 and the old high level consumer API. I wanted to implement atleast once semantics in my app, and looking around it seemed like the right way to do it is to: - set "auto.commit.enabled=false" for the consumer properties. - Then, issue a