filed: https://issues.apache.org/jira/browse/KAFKA-601
On Mon, Nov 5, 2012 at 11:55 AM, Jay Kreps <jay.kr...@gmail.com> wrote: > 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 > > >
