0.8-beta1 should come with ZK 3.3.4. Thanks,
Jun On Thu, Nov 14, 2013 at 11:09 AM, Yu, Libo <libo...@citi.com> wrote: > We are using the default one in 0.8-beta1. It should be 3.3.3. > According to the comment in the Jira, it is more like a zookeeper > configuration issue. I will make change to our configuration > and keep monitoring it. Thanks. > > Regards, > > Libo > > > -----Original Message----- > From: Jun Rao [mailto:jun...@gmail.com] > Sent: Thursday, November 14, 2013 12:27 PM > To: users@kafka.apache.org > Subject: Re: broker exception > > Are you using ZK 3.3.4? This seems to be caused by a bug in 3.3.3 and > 3.3.0. > > https://issues.apache.org/jira/browse/ZOOKEEPER-1115 > > Thanks, > > Jun > > > On Thu, Nov 14, 2013 at 5:25 AM, Yu, Libo <libo...@citi.com> wrote: > > > Hi team, > > > > This exception occurs regularly on our brokers. When it occurs, a > > broker will lose its leader role but still in ISR. And running > > preferred-leader-election script may rebalance the leadership but in > > some cases it does not help. > > > > [2013-11-14 08:04:40,001] INFO Processed session termination for > > sessionid: 0x34250e8160b0360 (org.apache.zookee > > per.server.PrepRequestProcessor) > > [2013-11-14 08:04:40,001] INFO Processed session termination for > > sessionid: 0x24250e816b00341 (org.apache.zookee > > per.server.PrepRequestProcessor) > > [2013-11-14 08:04:41,909] ERROR Unexpected exception causing shutdown > > while sock still open (org.apache.zookeepe > > r.server.quorum.LearnerHandler) > > java.io.EOFException > > at java.io.DataInputStream.readInt(DataInputStream.java:392) > > at > > org.apache.jute.BinaryInputArchive.readInt(BinaryInputArchive.java:63) > > at > > > org.apache.zookeeper.server.quorum.QuorumPacket.deserialize(QuorumPacket.java:84) > > at > > > org.apache.jute.BinaryInputArchive.readRecord(BinaryInputArchive.java:108) > > at > > org.apache.zookeeper.server.quorum.LearnerHandler.run(LearnerHandler.j > > ava:413) > > [2013-11-14 08:04:41,917] WARN ******* GOODBYE /xxx.xxx.xx.xx:59352 > > ******** (org.apache.zookeeper.server.quorum.LearnerHandler) > > [2013-11-14 08:04:41,926] INFO Got user-level KeeperException when > > processing sessionid:0x24250e816b00348 type:setData cxid:0x7e4 > > zxid:0xfffffffffffffffe txntype:unknown > > reqpath:/consumers/myusergroup/offsets/mytopic/1 Error Path:null > > Error:KeeperErrorCode = Session expired > > (org.apache.zookeeper.server.PrepRequestProcessor) > > [2013-11-14 08:04:42,000] INFO Expiring session 0x24242764c0b0000, > > timeout of 10000ms exceeded > > (org.apache.zookeeper.server.ZooKeeperServer) > > [2013-11-14 08:04:42,001] INFO Processed session termination for > > sessionid: 0x24242764c0b0000 > > (org.apache.zookeeper.server.PrepRequestProcessor) > > [2013-11-14 08:04:42,002] INFO Closed socket connection for client > > /xxx.xxx.xx.xx:41654 which had sessionid 0x24242764c0b0000 > > (org.apache.zookeeper.server.NIOServerCnxn) > > [2013-11-14 08:04:42,064] INFO Got user-level KeeperException when > > processing sessionid:0x14250e816040000 type:create cxid:0x11 > > zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a Error > > Path:/controller Error:KeeperErrorCode = NodeExists for /controller > > (org.apache.zookeeper.server.PrepRequestProcessor) > > [2013-11-14 08:04:42,065] INFO conflict in /controller data: 3 stored > > data: 2 (kafka.utils.ZkUtils$) > > [2013-11-14 08:04:42,067] INFO New leader is 2 > > (kafka.server.ZookeeperLeaderElector$LeaderChangeListener) > > > > > > > > Regards, > > > > Libo > > > > >