You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Sa Li <sa...@gmail.com> on 2015/05/15 00:14:55 UTC

connection refused between two VMs

Hi, All

I had experience to setup kafka cluster among physical servers, currently I setup two VMs, and I fire up 1 broker on each VMs, as (broker 0 and 2). I create a topic test-rep-1:

Topic:test-rep-1        PartitionCount:2        ReplicationFactor:1     Configs:
        Topic: test-rep-1       Partition: 0    Leader: 0       Replicas: 0     Isr: 0
        Topic: test-rep-1       Partition: 1    Leader: 2       Replicas: 2     Isr: 2

However, when I did producer test, I run such command:

bin/kafka-run-class.sh org.apache.kafka.clients.tools.ProducerPerformance test-rep-1 5000 1000 -1 acks=1 bootstrap.servers=sa-vm1:9092 buffer.memory=67108864 batch.size=8196

and keep getting connection refused error, like

[2015-05-14 15:05:13,961] WARN Error in I/O with sa-vm2/10.43.34.143 (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:238)
        at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
        at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
        at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:135)
        at java.lang.Thread.run(Thread.java:745)
[2015-05-14 15:05:13,972] WARN Error in I/O with sa-vm2/10.43.34.143 (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:238)
        at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
        at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
        at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:135)
        at java.lang.Thread.run(Thread.java:745)

Any clue to solve the connection issues among VMs.

Thanks

AL