windows 在端口2181上执行Kafka时出错- topic命令：等待节点分配时超时,OS Win 10

cig3rfwq 于 2022-11-18 发布在 Windows

关注(0)|答案(7)|浏览(300)

我已经在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中的某个位置，以在www.example.com文件中添加listener =PLAINTEXT：//127.0.0.1：9092server.properties，但这没有按预期工作。

windows

来源：https://stackoverflow.com/questions/58376644/error-while-executing-kafka-on-port-2181-topic-command-timed-out-waiting-for

7条答案

按热度按时间

rqqzpn5f1#

Zookeeper在2181上运行，而不是Kafka（引导服务器）
默认情况下，Kafka在端口9092上运行，如下所示

kafka-topics --bootstrap-server 127.0.0.1:9092 --topic first_topic --create --partitions 3 --replication-factor 1

赞(0）回复(0）举报 2022-11-18

blpfk2vs2#

我在linux上也遇到过同样的问题，推荐的创建主题的方法仍然是通过代理，你不需要直接连接到zookeeper。
事实证明，在连接到TLS端点时，shell脚本需要进行更多的配置：
1.将jdk链接到的证书复制到临时位置：

cp /usr/lib/jvm/java-11-openjdk-amd64/lib/security/cacerts /tmp/kafka.client.truststore.jks

1.创建属性文件（例如client.properties）

security.protocol=SSL
ssl.truststore.location=/tmp/kafka.client.truststore.jks

然后尝试再次运行该脚本，同时传递带有属性文件的选项--command-config，例如：

./kafka-topics.sh --bootstrap-server <server>:<port> --list --command-config client.properties

请注意，不同脚本之间的选项不一致，对于控制台使用者/生成者，您需要：--consumer.config和--producer.config

赞(0）回复(0）举报 2022-11-18

7uhlpewt3#

x1c 0d1x将bootstrap-server替换为zookeeper修复了此问题。

赞(0）回复(0）举报 2022-11-18

bn31dyow4#

对于版本2.，您必须使用zookeper创建主题，并将默认端口2181作为参数。
对于版本3.，zookeeper不再是一个参数，您应该使用localhost或服务器的IP地址和默认端口9092来使用--bootstrap-server。
文件

赞(0）回复(0）举报 2022-11-18

ev7lccsx5#

检查您的经纪人后，你得到这个错误，Kafka经纪人会给予你正确的IP地址在控制台这是运行在不同的终端.
在我的例子中，我用192.168.0.21：9092替换了127.0.0.1：2181，并且成功地创建了一个新主题。
注意：使用bootstrap而不是zookeeper。

赞(0）回复(0）举报 2022-11-18

91zkwejq6#

对于mac，当我使用带有Kafka服务器端口的引导服务器时，它对我的工作如下。最初，当我尝试使用zookeeper时失败了。

bin/kafka-topics.sh --bootstrap-server localhost:9092 --topic firsttopic --create --partitions 3 --replication-factor 1

赞(0）回复(0）举报 2022-11-18

xfyts7mz7#

我遇到了同样的问题，但之前一切都很好。
因此我更改了两个属性文件中的数据目录：zookeeper.properties和server.properties，它又开始正常工作了。这可能是因为我之前没有正确关闭代理和Zookeeper。

赞(0）回复(0）举报 2022-11-18

我来回答

windows 在端口2181上执行Kafka时出错- topic命令：等待节点分配时超时,OS Win 10

7条答案

相关问题

热门标签

最新问答