I'm still confused by the messages we're getting. It seems to coincide with rebalances. Does this mean that a broker is trying to take ownership of a partition that another broker already owns? Is this a normal message that's just a side effect of a rebalance?
>----------------------------------------------------------------- > > >Maybe I'm reading it wrong but doesn't the error indicate that the node exists? > > >-------------------------------------------------------------------- > > >That one is ok. It just means that a zk path doesn't exist. In this particular case, the path is not >expected to always exist. > > > >Thanks, > > > >Jun > > > > > On Tue, Mar 25, 2014 at 12:09 AM, Tom Amon <ta46...@gmail.com> wrote: > Whenever a session is expired by ZooKeeper I see the following > messages (one per consumer I think) in the ZooKeeper log: > > 2014-03-25 00:05:12,953 - INFO > [ProcessThread:-1:PrepRequestProcessor@419 > ] > - Got user-level KeeperException when processing > sessionid:0x344f675fcee0164 type:create cxid:0x7566 > zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a Error > Path:/consumers/optimizer-group/owners/optimizer-default-topic/724 > Error:KeeperErrorCode = NodeExists for > /consumers/optimizer-group/owners/optimizer-default-topic/724 > > Is this normal? Something the Kafka consumer recovers from? >
