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 >> Shutdown/Ctrl-C and ConsumerRebalanceFailedException


Copy link to this message
-
Re: Shutdown/Ctrl-C and ConsumerRebalanceFailedException
Makes sense.  Should we have that expanded in documentation somewhere?
ConsumerConnector.scala just has "Shut down the connector" for shutdown().

On 03/25/2012 11:47 PM, Jun Rao wrote:
> Chris,
>
> When ConsumerConnector.close is called, we close ZK connection, which
> should cause all ephemeral nodes to be deleted. Of course, the consumer app
> itself needs to add a shutdown hook that calls ConsumerConnector.close when
> the app is cleanly killed.
>
> Thanks,
>
> Jun
>
> On Sun, Mar 25, 2012 at 7:10 PM, Chris Burroughs
> <[EMAIL PROTECTED]>wrote:
>
>> On 03/25/2012 10:08 PM, Neha Narkhede wrote:
>>> If the consumer is shutdown, cleanly or not, zookeeper deletes the
>>> ephemeral nodes from its database.
>>> (unless you are using zk 3.3.3)
>>
>> Right but only after the timeout. I'm suggesting (and sorry if I'm
>> confusing by thinking we already did this) that we explicitly delete on
>> on clean shutdown so we don't force a n second service disruption on
>> every restart.
>>
>
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