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