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