Mahesh, Could you reformat your attached logs?
Guozhang On Mon, Jan 26, 2015 at 8:08 PM, Mahesh Kumar <maheshsanka...@outlook.com> wrote: > Hi all, I am currently working on logstash to mongodb.logstash's > input (producer) is kafka and output (consumer) is mongodb.It is worked > fine for past two days.Today it is not working and i got the following > error.i googled this error,still didnt find any correct solution.kindly > help me to resolve. > [2015-01-24 16:16:13,196] INFO [ReplicaFetcherManager on broker 0] Removed > fetcher for partitions [kafka3,0],[kafka3,1] > (kafka.server.ReplicaFetcherManager)[2015-01-24 16:16:17,443] ERROR Closing > socket for /10.10.10.25 because of error > (kafka.network.Processor)java.io.IOException: Connection reset by peerat > 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:379)at > kafka.utils.Utils$.read(Utils.scala:375)at > kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54)at > kafka.network.Processor.read(SocketServer.scala:347)at > kafka.network.Processor.run(SocketServer.scala:245)at > java.lang.Thread.run(Thread.java:744)[2015-01-24 16:16:55,956] INFO Closing > socket connection to /10.10.10.25. (kafka.network.Processor)[2015-01-24 > 16:19:49,285] ERROR Closing socket for /10.10.10.25 because of error > (kafka.network.Processor)java.io.IOException: Connection reset by peerat > 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:379)at > kafka.utils.Utils$.read(Utils.scala:375)at > kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54)at > kafka.network.Processor.read(SocketServer.scala:347)at > kafka.network.Processor.run(SocketServer.scala:245)at > java.lang.Thread.run(Thread.java:744)[2015-01-24 16:20:18,100] INFO Closing > socket connection to /10.10.10.25. (kafka.network.Processor)[2015-01-24 > 16:21:30,156] ERROR Closing socket for /10.10.10.25 because of error > (kafka.network.Processor)java.io.IOException: Connection reset by peerat > 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:379)at > kafka.utils.Utils$.read(Utils.scala:375)at > kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54)at > kafka.network.Processor.read(SocketServer.scala:347)at > kafka.network.Processor.run(SocketServer.scala:245)at > java.lang.Thread.run(Thread.java:744)[2015-01-24 17:49:56,224] INFO Closing > socket connection to /10.10.10.25. (kafka.network.Processor) > ThanksMahesh.S -- -- Guozhang
