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

Switch to Threaded View
Kafka >> mail # user >> Kafka server occure java.nio.BufferUnderflowException


Copy link to this message
-
Re: Kafka server occure java.nio.BufferUnderflowException
This could also be an implementation issue with the wire protocol in the c
library. Could you dump out the bytes in the request and see if it matches
the protocol specified in our wiki (
https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol
)?

Thanks,

Jun
On Wed, Jan 22, 2014 at 12:27 AM, ³ÂС¾ü <[EMAIL PROTECTED]> wrote:

> I use c  library (librdkafka)
>
>
> Best Regards
> Jerry
>
> -----Original Message-----
> *From:* "Jun Rao"<[EMAIL PROTECTED]>
> *To:* "[EMAIL PROTECTED]"<[EMAIL PROTECTED]>; "³ÂС¾ü"<
> [EMAIL PROTECTED]>;
> *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, ³ÂС¾ü <[EMAIL PROTECTED]> 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
>
>
>