Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # user >> shutting down consumer hang...


Copy link to this message
-
Re: shutting down consumer hang...
This sounds like a bug could you file a ticket for it?
On Mon, Nov 5, 2012 at 11:51 AM, Jason Rosenberg <[EMAIL PROTECTED]> 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
>
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB