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
