Does anybody have any clues? Please let me know if more details are required.
The problem is that the java web server based on High level consumer does not always receive messages but the publish and consume functionality is fine because the console consumer is consuming okay. Can it be something related to Garbage Collection in my webserver? If so, how to investigate? On Mon, Apr 11, 2016 at 12:45 PM, NISHANT BULCHANDANI < nbulchand...@gmail.com> wrote: > 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 > >
