三台机器部署了zookeeper、kafka集群,都成功启动,
打开终端,创建topic,成功,查看topic信息,正常
[root@node2 ~]$ kafka-topics.sh --zookeeper 192.168.220.135:2181,192.168.220.136:2181,192.168.220.137:2181/kafka --create --topic topic-demo03 --replication-factor 3 --partitions 3
Created topic topic-demo03.
[root@node2 ~]$ kafka-topics.sh --zookeeper 192.168.220.135:2181,192.168.220.136:2181,192.168.220.137:2181/kafka --describe --topic topic-demo03
Topic:topic-demo03 PartitionCount:3 ReplicationFactor:3 Configs:
Topic: topic-demo03 Partition: 0 Leader: 3 Replicas: 3,1,2 Isr: 3,1,2
Topic: topic-demo03 Partition: 1 Leader: 1 Replicas: 1,2,3 Isr: 1,2,3
Topic: topic-demo03 Partition: 2 Leader: 2 Replicas: 2,3,1 Isr: 2,3,1
使用自带客户端,发送消息,异常
[root@node1 ~]$ kafka-console-producer.sh --broker-list 192.168.220.135:2181,192.168.220.136:2181,192.168.220.137:2181 --topic topic-demo03
>hhhh\^H
[2022-03-03 12:25:00,749] ERROR Error when sending message to topic topic-demo03 with key: null, value: 6 bytes with error: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)
org.apache.kafka.common.errors.TimeoutException: Topic topic-demo03 not present in metadata after 60000 ms.
>
listeners=PLAINTEXT://192.168.220.137:9092
log.dirs=/usr/local/bin/kafka/logs
zookeeper.connect=192.168.220.135:2181,192.168.220.136:2181,192.168.220.137:2181/kafka
--broker-list是kafka节点的地址,不是zookeeper的地址。