Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

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


+
Yonghui Zhao 2013-03-18, 03:25
+
Jun Rao 2013-03-18, 16:25
+
Yonghui Zhao 2013-03-19, 07:29
+
Yonghui Zhao 2013-03-19, 08:35
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)

 
+
Yonghui Zhao 2013-03-21, 04:26
+
Jun Rao 2013-03-21, 15:14
+
Yonghui Zhao 2013-03-22, 03:39
+
Jun Rao 2013-03-22, 04:26
+
Yonghui Zhao 2013-03-22, 04:40
+
Jun Rao 2013-03-22, 04:55
+
Yonghui Zhao 2013-03-22, 06:08
+
Jun Rao 2013-03-22, 15:06
+
Yonghui Zhao 2013-03-22, 15:46
+
Yonghui Zhao 2013-03-25, 06:14
+
Neha Narkhede 2013-03-25, 13:49
+
Yonghui Zhao 2013-03-26, 02:14
+
Neha Narkhede 2013-03-26, 03:16
+
Yonghui Zhao 2013-03-26, 03:49
+
Neha Narkhede 2013-03-26, 15:40
+
Yonghui Zhao 2013-03-26, 16:48
+
Neha Narkhede 2013-03-27, 14:52
+
Yonghui Zhao 2013-03-28, 03:35
+
Jun Rao 2013-03-28, 04:54
+
Yonghui Zhao 2013-03-28, 07:23
+
Jun Rao 2013-03-28, 14:52
+
Yonghui Zhao 2013-03-28, 15:21
+
Jun Rao 2013-03-28, 15:25
+
Yonghui Zhao 2013-03-28, 15:32
+
Jun Rao 2013-03-29, 04:03
+
Yonghui Zhao 2013-03-22, 06:33
+
Ranjith Venkatesan 2014-02-02, 06:03
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB