HI Gwen,
Thanks for info appreciate. Sometime, I have observed duplicated events...
so that is why I ask.
Thanks,
Bhavesh
On Tue, Oct 28, 2014 at 11:51 AM, Gwen Shapira
wrote:
> High level consumer commits before shutting down.
>
> If you'll look at ZookeeperConsumerConnector.scala (currently
High level consumer commits before shutting down.
If you'll look at ZookeeperConsumerConnector.scala (currently the only
implementation of ConsumerConnector) you'll see shutdown() includes
the following:
if (config.autoCommitEnable)
commitOffsets()
Gwen
On Tue, Oct 28, 201
