Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # user >> Re: broker exception


Copy link to this message
-
Re: broker exception
0.8-beta1 should come with ZK 3.3.4.

Thanks,

Jun
On Thu, Nov 14, 2013 at 11:09 AM, Yu, Libo <[EMAIL PROTECTED]> 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:[EMAIL PROTECTED]]
> Sent: Thursday, November 14, 2013 12:27 PM
> To: [EMAIL PROTECTED]
> 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 <[EMAIL PROTECTED]> 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
> >
> >
>