windows - 在端口 2181 上执行 Kafka 时出错 - 主题命令:等待节点分配超时。操作系统赢 10
问题描述
我已经在 Windows 10 上配置了 kafka_2.11-2.3.0 和 apache-zookeeper-3.5.5-bin。但是在运行主题创建命令时,我收到以下错误:
C:\kafka_2.11-2.3.0>.\bin\windows\kafka-topics.bat --create --bootstrap-server 127.0.0.1:2181 --partitions 1 --replication-factor 1 --topic testD1
Error while executing topic command : org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.
[2019-10-14 16:42:40,603] ERROR java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.
at org.apache.kafka.common.internals.KafkaFutureImpl.wrapAndThrow(KafkaFutureImpl.java:45)
at org.apache.kafka.common.internals.KafkaFutureImpl.access$000(KafkaFutureImpl.java:32)
at org.apache.kafka.common.internals.KafkaFutureImpl$SingleWaiter.await(KafkaFutureImpl.java:89)
at org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:260)
at kafka.admin.TopicCommand$AdminClientTopicService.createTopic(TopicCommand.scala:178)
at kafka.admin.TopicCommand$TopicService$class.createTopic(TopicCommand.scala:149)
at kafka.admin.TopicCommand$AdminClientTopicService.createTopic(TopicCommand.scala:172)
at kafka.admin.TopicCommand$.main(TopicCommand.scala:60)
at kafka.admin.TopicCommand.main(TopicCommand.scala)
Caused by: org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.
阅读 stackoverflow 中的某处以在 server.properties 文件中添加 listeners=PLAINTEXT://127.0.0.1:9092 ,但这并没有按预期工作。
解决方案
Zookeeper 在 2181 上运行,而不是 Kafka(引导服务器)
默认情况下,Kafka 在端口9092上运行,如下所示
kafka-topics --bootstrap-server 127.0.0.1:9092 --topic first_topic --create --partitions 3 --replication-factor 1
推荐阅读
- wso2 - WSO2 Api manager 1.10.0 安全证书
- clojurescript - 在 ClojureScript 中将函数传递给包装的 React 组件
- android - Android Instrumented Test 有时会工作,有时会在生成覆盖率时失败
- python - 从 Python 中的文本文件中读取选定的条目
- jquery - 如何在不影响回调的情况下停止滚动动画(jQuery.animate())
- git - 将大文件夹添加到 git 存储库而不缓存到存储库?
- android - Android-Room 错误:包 javax.annotation.processing 不存在
- mysql - Laravel @foreach - 如何显示属于关系模型的每个值
- javascript - querySelectorAll 事件侦听器函数未正确迭代
- javascript - 我需要帮助尝试在 React 游戏中连接我的不同组件