Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # user >> Connection reset by peer


Copy link to this message
-
Re: Connection reset by peer
"Connect reset by peer" means the other side of the socket has closed the
connection for some reason. Could you provide the error/exception in both
the producer and the broker when a produce request fails?

Thanks,

Jun

On Tue, Mar 19, 2013 at 1:34 AM, Yonghui Zhao <[EMAIL PROTECTED]> wrote:

>  Connection reset exception reproed.
>
> [2013-03-19 16:30:45,814] INFO Closing socket connection to /127.0.0.1.
> (kafka.network.Processor)
> [2013-03-19 16:30:55,253] ERROR Closing socket for /127.0.0.1 because of
> error (kafka.network.Processor)
> java.io.IOException: Connection reset by peer
>     at sun.nio.ch.FileDispatcher.read0(Native Method)
>     at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39)
>     at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:251)
>     at sun.nio.ch.IOUtil.read(IOUtil.java:224)
>     at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:254)
>     at kafka.utils.Utils$.read(Utils.scala:538)
>     at
>
> kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54)
>     at kafka.network.Processor.read(SocketServer.scala:311)
>     at kafka.network.Processor.run(SocketServer.scala:214)
>     at java.lang.Thread.run(Thread.java:679)
> [2013-03-19 16:31:02,476] ERROR Closing socket for /127.0.0.1 because of
> error (kafka.network.Processor)
> java.io.IOException: Connection reset by peer
>     at sun.nio.ch.FileDispatcher.read0(Native Method)
>     at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39)
>     at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:251)
>     at sun.nio.ch.IOUtil.read(IOUtil.java:224)
>     at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:254)
>     at kafka.utils.Utils$.read(Utils.scala:538)
>     at
>
> kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54)
>     at kafka.network.Processor.read(SocketServer.scala:311)
>     at kafka.network.Processor.run(SocketServer.scala:214)
>     at java.lang.Thread.run(Thread.java:679)
>
>
> 2013/3/19 Yonghui Zhao <[EMAIL PROTECTED]>
>
> > Thanks Jun.
> >
> > Now I use onebox to test kafka, kafka server ip on zk is 127.0.0.1,
> > network is not affected by external factors.
> >
> > Reset connection is not reproed, but I still find Broken pipe exceptions
> > and a few zk exceptions.
> >
> > [2013-03-19 15:23:28,660] INFO Closed socket connection for client /
> > 127.0.0.1:51902 which had sessionid 0x13d8152007b002c
> > (org.apache.zookeeper.server.NIOServerCnxn)
> > [2013-03-19 15:23:28,672] ERROR Unexpected Exception:
> > (org.apache.zookeeper.server.NIOServerCnxn)
> > java.nio.channels.CancelledKeyException
> >     at sun.nio.ch.SelectionKeyImpl.ensureValid(SelectionKeyImpl.java:73)
> >     at sun.nio.ch.SelectionKeyImpl.interestOps(SelectionKeyImpl.java:77)
> >     at
> >
> org.apache.zookeeper.server.NIOServerCnxn.sendBuffer(NIOServerCnxn.java:418)
> >     at
> >
> org.apache.zookeeper.server.NIOServerCnxn.sendResponse(NIOServerCnxn.java:1509)
> >     at
> >
> org.apache.zookeeper.server.FinalRequestProcessor.processRequest(FinalRequestProcessor.java:171)
> >     at
> >
> org.apache.zookeeper.server.SyncRequestProcessor.run(SyncRequestProcessor.java:135)
> >
> >
> >
> > [2013-03-19 15:15:58,355] INFO Closing socket connection to /127.0.0.1.
> > (kafka.network.Processor)
> > [2013-03-19 15:16:00,161] INFO Closing socket connection to /127.0.0.1.
> > (kafka.network.Processor)
> > [2013-03-19 15:16:01,784] INFO Closing socket connection to /127.0.0.1.
> > (kafka.network.Processor)
> > [2013-03-19 15:16:04,751] INFO Closing socket connection to /127.0.0.1.
> > (kafka.network.Processor)
> > [2013-03-19 15:16:07,734] ERROR Closing socket for /127.0.0.1 because of
> > error (kafka.network.Processor)
> > java.io.IOException: Broken pipe
> >
> >     at sun.nio.ch.FileChannelImpl.transferTo0(Native Method)
> >     at
> > sun.nio.ch.FileChannelImpl.transferToDirectly(FileChannelImpl.java:456)
> >     at sun.nio.ch.FileChannelImpl.transferTo(FileChannelImpl.java:557)