This sounds like a bug could you file a ticket for it?
On Mon, Nov 5, 2012 at 11:51 AM, Jason Rosenberg <j...@squareup.com> wrote: > Hi, > > I have a situation where I want to reliably shut-down a consumer, but it > seems to hang in certain conditions, namely: > > - If autocommit.enabled = true > - If the current zk instance is not available > > It seems that it will indefinitely try to re-create the zk connection, in > order to auto-commit, before exiting, even after I've called > ConsumerConnector.shutdown(). > > I would think that there should be a way to force it to shutdown, even > under error conditions. > > Thoughts? > > Jason >
