kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From arathi maddula <arathimadd...@gmail.com>
Subject Issue during commitOffsets using SimpleConsumer
Date Thu, 30 May 2013 18:22:56 GMT
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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message