scala KeeperErrorCode = NoNode for /brokers/topics/test-topic/partitions

声明:本页面是StackOverFlow热门问题的中英对照翻译,遵循CC BY-SA 4.0协议,如果您需要使用它,必须同样遵循CC BY-SA许可,注明原文地址和作者信息,同时你必须将它归于原作者(不是我):StackOverFlow 原文地址: http://stackoverflow.com/questions/26879777/
Warning: these are provided under cc-by-sa 4.0 license. You are free to use/share it, But you must attribute it to the original authors (not me): StackOverFlow

提示:将鼠标放在中文语句上可以显示对应的英文。显示中英文
时间:2020-10-22 06:41:57  来源:igfitidea点击:

KeeperErrorCode = NoNode for /brokers/topics/test-topic/partitions

scalaapache-kafka

提问by Kshitij Kulshrestha

While starting Kafka getting this following error.

在启动 Kafka 时出现以下错误。

KeeperErrorCode = NoNode for /brokers/topics/test-topic/partitions

Any help will be apreciated.

任何帮助将不胜感激。

采纳答案by Kshitij Kulshrestha

I found my answer, It is because of version mismatch of zookeeper and kafka. Previously I was using kafka_2.8.0-0.8.0 with zookeeper 3.3.5 but then I installed kafka_2.9.2-0.8.1.1 with zookeeper 3.3.5 and now It's working fine.

我找到了答案,这是因为 zookeeper 和 kafka 的版本不匹配。以前我在zookeeper 3.3.5上使用kafka_2.8.0-0.8.0,但后来我在zookeeper 3.3.5上安装了kafka_2.9.2-0.8.1.1,现在它工作正常。

回答by Denis Makarenko

Most likely this is because the topic is not created yet. Topic nodes in Zookeeper are created when broker processes the first message to the topic or, alternatively, when the AdminUtils.createTopic(...) call was made.

这很可能是因为尚未创建主题。Zookeeper 中的主题节点是在代理处理主题的第一条消息时创建的,或者,在进行 AdminUtils.createTopic(...) 调用时创建。