【发布时间】:2015-01-08 21:07:51
【问题描述】:
在启动 Kafka 时出现以下错误。
KeeperErrorCode = NoNode for /brokers/topics/test-topic/partitions
我们将不胜感激。
【问题讨论】:
-
一次又一次,不向我们展示您的配置,是不可能提供帮助的。
标签: scala apache-kafka
在启动 Kafka 时出现以下错误。
KeeperErrorCode = NoNode for /brokers/topics/test-topic/partitions
我们将不胜感激。
【问题讨论】:
标签: scala apache-kafka
我找到了答案,这是因为zookeeper和kafka的版本不匹配。 以前我使用 kafka_2.8.0-0.8.0 和 zookeeper 3.3.5 但后来我用 zookeeper 3.3.5 安装了 kafka_2.9.2-0.8.1.1,现在它工作正常。
【讨论】:
这很可能是因为尚未创建主题。 Zookeeper 中的主题节点是在代理处理该主题的第一条消息时创建的,或者在调用 AdminUtils.createTopic(...) 时创建。
【讨论】: