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 <[email protected]>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 >
