Any issue with the network? Thanks,
Jun On Wed, Jan 7, 2015 at 1:59 PM, Sa Li <sal...@gmail.com> wrote: > Things bother me, sometimes, the errors won't pop out, sometimes it comes, > why? > > On Wed, Jan 7, 2015 at 1:49 PM, Sa Li <sal...@gmail.com> wrote: > > > > > Hi, Experts > > > > Our cluster is a 3 nodes cluster, I simply test producer locally, see > > > > bin/kafka-run-class.sh org.apache.kafka.clients.tools.ProducerPerformance > > test-rep-three 1000000 3000 -1 acks=1 bootstrap.servers= > 10.100.98.100:9092 > > buffer.memory=67108864 batch.size=8196 > > > > But I got such error, I do think this is critical issue, it just > > temporally lose the connection and get back, what is the reason for this? > > > > [2015-01-07 21:44:14,180] WARN Error in I/O with voluminous-mass.master/ > > 10.100.98.101 (org.apache.kafka.common.network.Selector) > > java.net.ConnectException: Connection refused > > at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) > > at > > sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:739) > > at > org.apache.kafka.common.network.Selector.poll(Selector.java:232) > > at > > org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:191) > > at > > org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:184) > > at > > org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:115) > > at java.lang.Thread.run(Thread.java:745) > > [2015-01-07 21:44:14,190] WARN Error in I/O with voluminous-mass.master/ > > 10.100.98.101 (org.apache.kafka.common.network.Selector) > > java.net.ConnectException: Connection refused > > at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) > > at > > sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:739) > > at > org.apache.kafka.common.network.Selector.poll(Selector.java:232) > > at > > org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:191) > > at > > org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:184) > > at > > org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:115) > > at java.lang.Thread.run(Thread.java:745) > > [2015-01-07 21:44:14,200] WARN Error in I/O with voluminous-mass.master/ > > 10.100.98.101 (org.apache.kafka.common.network.Selector) > > java.net.ConnectException: Connection refused > > at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) > > at > > sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:739) > > at > org.apache.kafka.common.network.Selector.poll(Selector.java:232) > > at > > org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:191) > > at > > org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:184) > > at > > org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:115) > > at java.lang.Thread.run(Thread.java:745) > > [2015-01-07 21:44:14,210] WARN Error in I/O with voluminous-mass.master/ > > 10.100.98.101 (org.apache.kafka.common.network.Selector) > > java.net.ConnectException: Connection refused > > at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) > > at > > sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:739) > > at > org.apache.kafka.common.network.Selector.poll(Selector.java:232) > > at > > org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:191) > > at > > org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:184) > > at > > org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:115) > > at java.lang.Thread.run(Thread.java:745) > > [2015-01-07 21:44:14,220] WARN Error in I/O with voluminous-mass.master/ > > 10.100.98.101 (org.apache.kafka.common.network.Selector) > > java.net.ConnectException: Connection refused > > at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) > > at > > sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:739) > > at > org.apache.kafka.common.network.Selector.poll(Selector.java:232) > > at > > org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:191) > > at > > org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:184) > > at > > org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:115) > > at java.lang.Thread.run(Thread.java:745) > > [2015-01-07 21:44:14,230] WARN Error in I/O with voluminous-mass.master/ > > 10.100.98.101 (org.apache.kafka.common.network.Selector) > > java.net.ConnectException: Connection refused > > at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) > > at > > sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:739) > > at > org.apache.kafka.common.network.Selector.poll(Selector.java:232) > > at > > org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:191) > > at > > org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:184) > > at > > org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:115) > > at java.lang.Thread.run(Thread.java:745) > > [2015-01-07 21:44:14,240] WARN Error in I/O with voluminous-mass.master/ > > 10.100.98.101 (org.apache.kafka.common.network.Selector) > > java.net.ConnectException: Connection refused > > at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) > > at > > sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:739) > > at > org.apache.kafka.common.network.Selector.poll(Selector.java:232) > > at > > org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:191) > > at > > org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:184) > > at > > org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:115) > > at java.lang.Thread.run(Thread.java:745) > > 80 records sent, 13.6 records/sec (0.04 MB/sec), 31113.8 ms avg latency, > > 46912.0 max latency. > > 116695 records sent, 23339.0 records/sec (66.77 MB/sec), 5157.1 ms avg > > latency, 46946.0 max latency. > > > > > > thanks > > > > -- > > > > Alec Li > > > > > > -- > > Alec Li >
