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. >> >
