本文主要是介绍Kafka 执行命令超时异常： Timed out waiting for a node assignment，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
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信息。
到此，问题解决。
这篇关于Kafka 执行命令超时异常： Timed out waiting for a node assignment的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
