我正在尝试在本地计算机上使用 java 11 设置 kafka 3.1.0。但是,在列出现有主题时,我遇到超时异常。
遵循的步骤:
启动zookeeper服务器: Zookeeper-server-start.bat config\zookeeper.properties
启动kafka服务器: kafka-server-start.bat config\server.properties
列出主题的命令: kafka-topics --bootstrap-server localhost:2181 --list
C:\kafka_2.13-3.1.0>kafka-topics --bootstrap-server localhost:2181 --list 执行主题命令时出错:等待节点分配超时。调用:listTopics [2022-02-19 20:11:37,239] 错误 org.apache.kafka.common.errors.TimeoutException:等待节点分配超时。调用:listTopics (kafka.admin.TopicCommand$)
我解决了这个问题。基本上,我在 server.properties 中启用了侦听器,如下所示,
听众=明文://localhost:9092
然后在运行 list 命令时将端口号更改为 9092
C:\kafka_2.13-3.1.0>kafka-topics --bootstrap-server localhost:9092 --list
第一个_主题
C:\kafka_2.13-3.1.0>
这对我有用,非常感谢!!