i?? m a beginner of kafka. i usde kafka_2.11-0.9.0.1. my kafka built in two
virtual machine which ip are 52.193 and 52.194
when i use commonds both in 52.193./kafka-console-producer.sh --broker-list
192.168.52.193:9092 --topic shuaige
and
./kafka-console-consumer.sh --zookeeper 192.168.52.195:2181 --topic shuaige
--from-beginning
the message of producer was shown in consumer terminal.
but when i use 52.193 as producer and 52.194 as consumer
./kafka-console-producer.sh --broker-list 192.168.52.194:9092 --topic shuaige
and
./kafka-console-consumer.sh --zookeeper 192.168.52.195:2181 --topic shuaige
--from-beginning
it shows WARN Error while fetching metadata with correlation id 0 :
{ttes=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
[2017-12-25 15:22:19,571] WARN Error while fetching metadata with correlation
id 1 : {ttes=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
[2017-12-25 15:22:19,675] WARN Error while fetching metadata with correlation
id 2 : {ttes=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
here is my configure,server.properties
# The id of the broker. This must be set to a unique integer for each broker.
broker.id=0
############################# Socket Server Settings
#############################
listeners=PLAINTEXT://:9092
port=9092
# The port the socket server listens on
#port=9092
# Hostname the broker will bind to. If not set, the server will bind to all
interfaces
#host.name=localhost
host.name=192.168.52.193
advertised.host.name = localhost
advertised.port=9092
num.network.threads=3
# The number of threads doing disk I/O
num.io.threads=8
# The send buffer (SO_SNDBUF) used by the socket server
socket.send.buffer.bytes=102400
# The receive buffer (SO_RCVBUF) used by the socket server
socket.receive.buffer.bytes=102400
# The maximum size of a request that the socket server will accept (protection
against OOM)
socket.request.max.bytes=104857600
############################# Log Basics #############################
num.partitions=1
num.recovery.threads.per.data.dir=1
log.retention.hours=168
message.max.byte=5242880
default.replication.factor=2
replica.fetch.max.bytes=5242880
log.segment.bytes=1073741824
log.retention.check.interval.ms=300000
############################# Zookeeper #############################
zookeeper.connect=192.168.52.195:2181,192.168.52.196:2181,192.168.52.197:2181
# Timeout in ms for connecting to zookeeper
zookeeper.connection.timeout.ms=6000
..thanks for you help
