Yes, it indicates a collision. Typically, this is caused by transient inconsistent views from different consumers.
Thanks, Jun On Fri, Mar 28, 2014 at 4:57 PM, Tom Amon <ta46...@gmail.com> wrote: > 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? > > > > > >
