Co java.io.EOFException exception with kafka_2.9.2-0.8.1.1

[raviorteja]

Hi,

I am using kafka_2.9.2-0.8.1.1 version of kafka and the kafka river plugin.
I get this error, even though all my configurations are correct.
I am not sure why this exception is encountered.

[2014-09-16 14:13:20,376][INFO ][kafka.consumer.SimpleConsumer] Reconnect in fetch request due to socket error:
java.io.EOFException: Received -1 when reading from channel, socket has likely been closed.
at kafka.utils.Utils$.read(Utils.scala:539)
at kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54)
at kafka.network.Receive$class.readCompletely(Transmission.scala:55)
at kafka.network.BoundedByteBufferReceive.readCompletely(BoundedByteBufferReceive.scala:29)
at kafka.consumer.SimpleConsumer.getResponse(SimpleConsumer.scala:177)
at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:83)
at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:81)
at kafka.javaapi.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:43)
at org.elasticsearch.river.kafka.KafkaClient.fetch(KafkaClient.java:101)
at org.elasticsearch.river.kafka.KafkaRiver$KafkaRiverWorker.run(KafkaRiver.java:271)
at java.lang.Thread.run(Thread.java:744)
[2014-09-16 14:13:20,379][ERROR][river.kafka ] [Quicksand] [kafka][countergenerater_kafka_river_chb1] Error fetching from Kafka(hostname_123:9092/ravi_test:0), retrying in 5 sec
java.io.EOFException: Received -1 when reading from channel, socket has likely been closed.
at kafka.utils.Utils$.read(Utils.scala:539)
at kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54)
at kafka.network.Receive$class.readCompletely(Transmission.scala:55)
at kafka.network.BoundedByteBufferReceive.readCompletely(BoundedByteBufferReceive.scala:29)
at kafka.consumer.SimpleConsumer.getResponse(SimpleConsumer.scala:177)
at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:91)
at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:81)
at kafka.javaapi.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:43)
at org.elasticsearch.river.kafka.KafkaClient.fetch(KafkaClient.java:101)
at org.elasticsearch.river.kafka.KafkaRiver$KafkaRiverWorker.run(KafkaRiver.java:271)
at java.lang.Thread.run(Thread.java:744)