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:
>
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