时间戳

首页 > 解决方案 > Kafka，等待节点分配的超时？

macos - Kafka，等待节点分配的超时？

问题描述

按照入门指南，我收到以下错误：

org.apache.kafka.common.errors.TimeoutException：等待节点分配超时。(kafka.admin.TopicCommand$)

我所做的是使用以下命令启动两台服务器：

bin/zookeeper-server-start.sh config/zookeeper.properties

和

bin/kafka-server-start.sh config/server.properties

然后执行以下命令，我收到错误：

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

我在 macOS Mojave 上运行

启动 Kafka 服务器时，我获得了以下日志：

[2019-12-08 17:50:53,929] INFO Got user-level KeeperException when processing sessionid:0x10002516aaf0000 type:create cxid:0x2 zxid:0x3 txntype:-1 reqpath:n/a Error Path:/brokers Error:KeeperErrorCode = NoNode for /brokers (org.apache.zookeeper.server.PrepRequestProcessor)
[2019-12-08 17:50:53,957] INFO Got user-level KeeperException when processing sessionid:0x10002516aaf0000 type:create cxid:0x6 zxid:0x7 txntype:-1 reqpath:n/a Error Path:/config Error:KeeperErrorCode = NoNode for /config (org.apache.zookeeper.server.PrepRequestProcessor)
[2019-12-08 17:50:53,977] INFO Got user-level KeeperException when processing sessionid:0x10002516aaf0000 type:create cxid:0x9 zxid:0xa txntype:-1 reqpath:n/a Error Path:/admin Error:KeeperErrorCode = NoNode for /admin (org.apache.zookeeper.server.PrepRequestProcessor)
[2019-12-08 17:50:54,282] INFO Got user-level KeeperException when processing sessionid:0x10002516aaf0000 type:create cxid:0x15 zxid:0x15 txntype:-1 reqpath:n/a Error Path:/cluster Error:KeeperErrorCode = NoNode for /cluster (org.apache.zookeeper.server.PrepRequestProcessor)
[2019-12-08 17:50:55,247] INFO Got user-level KeeperException when processing sessionid:0x10002516aaf0000 type:multi cxid:0x37 zxid:0x1c txntype:-1 reqpath:n/a aborting remaining multi ops. Error Path:/admin/preferred_replica_election Error:KeeperErrorCode = NoNode for /admin/preferred_replica_election (org.apache.zookeeper.server.PrepRequestProcessor)

标签： macosapache-kafka

解决方案

Apache Kafka 带有不完整的配置。

对我有用的是更改 server.properties 启用 listeners 参数。

listeners=PLAINTEXT://localhost:9092

请注意，示例禁用行缺少主机名（listeners=://localhost:9092）

推荐阅读