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
