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

[Jun Rao]

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 <davidmontgom...@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
>