You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by David Montgomery <da...@gmail.com> on 2014/02/06 08:31:12 UTC

Closing socket for /222.127. xxx.xxx because of error (kafka.network.Processor)

Hi,

I am using the python brod library to write to kafka 8.0.

I am on a 2 core server with 4 gigs of ram on ubuntu 12.04

I have zero clue what the below error means. How do I tweak kafka to get it
to work?


[2014-02-06 07:21:57,001] INFO Closing socket connection to
/222.127.xxx.xxx. (kafka.network.Processor)
[2014-02-06 07:24:15,353] ERROR Closing socket for /222.127. xxx.xxx
because of error (kafka.network.Processor)
java.nio.BufferUnderflowException
    at java.nio.HeapByteBuffer.get(HeapByteBuffer.java:145)
    at java.nio.ByteBuffer.get(ByteBuffer.java:694)
    at kafka.api.ApiUtils$.readShortString(ApiUtils.scala:38)
    at kafka.api.ProducerRequest$.readFrom(ProducerRequest.scala:33)
    at kafka.api.RequestKeys$$anonfun$1.apply(RequestKeys.scala:34)
    at kafka.api.RequestKeys$$anonfun$1.apply(RequestKeys.scala:34)
    at kafka.network.RequestChannel$Request.<init>(RequestChannel.scala:49)
    at kafka.network.Processor.read(SocketServer.scala:353)
    at kafka.network.Processor.run(SocketServer.scala:245)
    at java.lang.Thread.run(Thread.java:744)
[2014-02-06 07:24:56,669] ERROR Closing socket for /222.127.xxx.xxx.
because of error (kafka.network.Processor)
java.nio.BufferUnderflowException
    at java.nio.HeapByteBuffer.get(HeapByteBuffer.java:145)
    at java.nio.ByteBuffer.get(ByteBuffer.java:694)
    at kafka.api.ApiUtils$.readShortString(ApiUtils.scala:38)
    at kafka.api.ProducerRequest$.readFrom(ProducerRequest.scala:33)
    at kafka.api.RequestKeys$$anonfun$1.apply(RequestKeys.scala:34)
    at kafka.api.RequestKeys$$anonfun$1.apply(RequestKeys.scala:34)
    at kafka.network.RequestChannel$Request.<init>(RequestChannel.scala:49)
    at kafka.network.Processor.read(SocketServer.scala:353)
    at kafka.network.Processor.run(SocketServer.scala:245)
    at java.lang.Thread.run(Thread.java:744)


Thanks

Re: Closing socket for /222.127. xxx.xxx because of error (kafka.network.Processor)

Posted by Jun Rao <ju...@gmail.com>.

This typically means the broker received a corrupted request. Did you write
the python producer yourself?

Thanks,

Jun


On Wed, Feb 5, 2014 at 11:31 PM, David Montgomery <davidmontgomery@gmail.com
> wrote:

> Hi,
>
> I am using the python brod library to write to kafka 8.0.
>
> I am on a 2 core server with 4 gigs of ram on ubuntu 12.04
>
> I have zero clue what the below error means. How do I tweak kafka to get it
> to work?
>
>
> [2014-02-06 07:21:57,001] INFO Closing socket connection to
> /222.127.xxx.xxx. (kafka.network.Processor)
> [2014-02-06 07:24:15,353] ERROR Closing socket for /222.127. xxx.xxx
> because of error (kafka.network.Processor)
> java.nio.BufferUnderflowException
>     at java.nio.HeapByteBuffer.get(HeapByteBuffer.java:145)
>     at java.nio.ByteBuffer.get(ByteBuffer.java:694)
>     at kafka.api.ApiUtils$.readShortString(ApiUtils.scala:38)
>     at kafka.api.ProducerRequest$.readFrom(ProducerRequest.scala:33)
>     at kafka.api.RequestKeys$$anonfun$1.apply(RequestKeys.scala:34)
>     at kafka.api.RequestKeys$$anonfun$1.apply(RequestKeys.scala:34)
>     at kafka.network.RequestChannel$Request.<init>(RequestChannel.scala:49)
>     at kafka.network.Processor.read(SocketServer.scala:353)
>     at kafka.network.Processor.run(SocketServer.scala:245)
>     at java.lang.Thread.run(Thread.java:744)
> [2014-02-06 07:24:56,669] ERROR Closing socket for /222.127.xxx.xxx.
> because of error (kafka.network.Processor)
> java.nio.BufferUnderflowException
>     at java.nio.HeapByteBuffer.get(HeapByteBuffer.java:145)
>     at java.nio.ByteBuffer.get(ByteBuffer.java:694)
>     at kafka.api.ApiUtils$.readShortString(ApiUtils.scala:38)
>     at kafka.api.ProducerRequest$.readFrom(ProducerRequest.scala:33)
>     at kafka.api.RequestKeys$$anonfun$1.apply(RequestKeys.scala:34)
>     at kafka.api.RequestKeys$$anonfun$1.apply(RequestKeys.scala:34)
>     at kafka.network.RequestChannel$Request.<init>(RequestChannel.scala:49)
>     at kafka.network.Processor.read(SocketServer.scala:353)
>     at kafka.network.Processor.run(SocketServer.scala:245)
>     at java.lang.Thread.run(Thread.java:744)
>
>
> Thanks
>