I use c  library (librdkafka)

Best Regards
Jerry
-----Original Message-----
From: "Jun Rao"<jun...@gmail.com> 
To: "users@kafka.apache.org"<users@kafka.apache.org>; 
"陈小军"<chenxiao...@nhn.com>; 
Cc: 
Sent: 2014-01-22 (星期三) 00:44:59
Subject: Re: Kafka server occure java.nio.BufferUnderflowException
 
This means that the broker somehow gets a corrupted TopicMetadata request. Are 
you using the java/scala client? Thanks, Jun 


On Mon, Jan 20, 2014 at 10:30 PM, 陈小军 <chenxiao...@nhn.com> wrote:

Hi all,

   in my kafka cluster, it alway ocuure following erro logs



[2014-01-21 15:25:24,462] ERROR Closing socket for /10.99.116.54 because of 
error (kafka.network.Processor)

java.nio.BufferUnderflowException

        at java.nio.Buffer.nextGetIndex(Buffer.java:498)

        at java.nio.HeapByteBuffer.getShort(HeapByteBuffer.java:304)

        at kafka.api.ApiUtils$.readShortString(ApiUtils.scala:34)

        at 
kafka.api.TopicMetadataRequest$$anonfun$readFrom$1.apply(TopicMetadataRequest.scala:44)

        at 
kafka.api.TopicMetadataRequest$$anonfun$readFrom$1.apply(TopicMetadataRequest.scala:43)

        at scala.collection.immutable.Range$ByOne$class.foreach(Range.scala:285)

        at scala.collection.immutable.Range$$anon$2.foreach(Range.scala:265)

        at 
kafka.api.TopicMetadataRequest$.readFrom(TopicMetadataRequest.scala:43)

        at kafka.api.RequestKeys$$anonfun$4.apply(RequestKeys.scala:39)

        at kafka.api.RequestKeys$$anonfun$4.apply(RequestKeys.scala:39)

        at 
kafka.network.RequestChannel$Request.<init>(RequestChannel.scala:50)

        at kafka.network.Processor.read(SocketServer.scala:353)

        at kafka.network.Processor.run(SocketServer.scala:245)

        at java.lang.Thread.run(Thread.java:744)



does someone also have this problem??





Best Regards

Jerry

 


Reply via email to