Home | About | Sematext search-lucene.com search-hadoop.com
 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
>> 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.