Hi Everyone, We are using the Kafka High level consumer in our web server to consume messages.
Sometimes, when i am running the message producer, Kafka & the webserver all 3 on my localhost ; the webserver does not recieve any messages & i see the below logs in *kafka.log* log file : [2016-04-11 12:36:43,448] ERROR *Closing socket for /127.0.0.1 <http://127.0.0.1> because of error (kafka.network.Processor)* java.io.IOException: Connection reset by peer at sun.nio.ch.FileDispatcherImpl.read0(Native Method) at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39) at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223) at sun.nio.ch.IOUtil.read(IOUtil.java:197) at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:384) at kafka.utils.Utils$.read(Utils.scala:380) at kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54) at kafka.network.Processor.read(SocketServer.scala:444) at kafka.network.Processor.run(SocketServer.scala:340) at java.lang.Thread.run(Thread.java:745) *Notably, the console consumer works fine even at this point.* However, this happens only sometimes; i have had this working earlier. I have also raised a StckOverlow question for this - http://stackoverflow.com/questions/36542139/kafka-high-level-consumer-not-consuming-messages-socket-closure-issue . What could be the problem here? Regards, Nishant
