Kafka 实行命令超时异常: Timed out waiting for a node assignment
问题形貌:
搭建了一个kafka集群情况,在利用命令行查察已有topic时,报错如下:
- [root@localhost bin]# kafka-topics.sh --list --bootstrap-server 192.168.135.132:9092,192.168.135.133:9092,192.168.135.134:9092
- Error while executing topic command : Timed out waiting for a node assignment. Call: listTopics
- [2024-05-08 20:39:59,123] ERROR org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment. Call: listTopics
- (org.apache.kafka.tools.TopicCommand)
复制代码
问题分析:
由于刚学习 kafka搭建集群,根据网上教程来,教程中三台kafka都部署在同一台机器上,以是不必要额外指定kafka气力的ip地址。
而我的情况是利用了三台虚拟机,分别部署了zookeeper和kafka,以是在没有指定的情况下,默认都是利用localhost,在实行命令的时间,会找不到对应的ip地址。
问题办理:
修改 kafka 设置文件:
/usr/local/kafka_2.12-3.7.0/config/server.properties
- listeners=PLAINTEXT://192.168.135.132:9092
复制代码
将三台机器的设置ip改为虚拟机ip地址。
修改保存后,再去重启kafka。
- /usr/local/kafka_2.12-3.7.0/bin/kafka-server-stop.sh
- /usr/local/kafka_2.12-3.7.0/bin/kafka-server-start.sh -daemon /usr/local/kafka_2.12-3.7.0/config/server.properties
复制代码 通过在zookeeper上查察节点信息,
进入zookeeper客户端:
- /usr/local/apache-zookeeper-3.8.4-bin/bin/zkCli.sh
复制代码 查察kafka节点信息:
- get /kafka/brokers/ids/1
- get /kafka/brokers/ids/2
- get /kafka/brokers/ids/3
复制代码
其中ip信息也改成了真实ip信息。
到此,问题办理。
免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!更多信息从访问主页:qidao123.com:ToB企服之家,中国第一个企服评测及商务社交产业平台。 |