You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by arathi maddula <ar...@gmail.com> on 2013/05/30 20:22:56 UTC
Issue during commitOffsets using SimpleConsumer
Hi,
I get the following error on running SimpleConsumer.commitOffsets(). Could
you tell me what is the issue?
*java.io.EOFException*: Received -1 when reading from channel, socket has
likely been closed.
at kafka.utils.Utils$.read(Utils.scala:375)
at
kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54)
at kafka.network.Receive$class.readCompletely(Transmission.scala:56)
at
kafka.network.BoundedByteBufferReceive.readCompletely(BoundedByteBufferReceive.scala:29)
at kafka.network.BlockingChannel.receive(BlockingChannel.scala:100)
at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:83)
at
kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:73)
at kafka.consumer.SimpleConsumer.commitOffsets(SimpleConsumer.scala:134)
at
kafka.javaapi.consumer.SimpleConsumer.commitOffsets(SimpleConsumer.scala:89)
at KafkaConsumer2.main(*KafkaConsumer2.java:226*)
Thanks
Arathi
Re: Issue during commitOffsets using SimpleConsumer
Posted by Jun Rao <ju...@gmail.com>.
This indicates an error on the broker. Any error/exception on the broker?
Also, you are using trunk. The stable unreleased branch is 0.8.
Thanks,
Jun
On Thu, May 30, 2013 at 11:22 AM, arathi maddula <ar...@gmail.com>wrote:
> Hi,
> I get the following error on running SimpleConsumer.commitOffsets(). Could
> you tell me what is the issue?
>
>
>
> *java.io.EOFException*: Received -1 when reading from channel, socket has
> likely been closed.
>
> at kafka.utils.Utils$.read(Utils.scala:375)
>
> at
>
> kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54)
>
> at kafka.network.Receive$class.readCompletely(Transmission.scala:56)
>
> at
>
> kafka.network.BoundedByteBufferReceive.readCompletely(BoundedByteBufferReceive.scala:29)
>
> at kafka.network.BlockingChannel.receive(BlockingChannel.scala:100)
>
> at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:83)
>
> at
>
> kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:73)
>
> at kafka.consumer.SimpleConsumer.commitOffsets(SimpleConsumer.scala:134)
>
> at
>
> kafka.javaapi.consumer.SimpleConsumer.commitOffsets(SimpleConsumer.scala:89)
>
> at KafkaConsumer2.main(*KafkaConsumer2.java:226*)
>
> Thanks
> Arathi
>