在启动Kafka时出现以下错误。
KeeperErrorCode = NoNode for /brokers/topics/test-topic/partitions
任何帮助都将受到感激。
cgyqldqp1#
很可能是因为主题尚未创建。zookeeper中的主题节点是在broker处理指向该主题的第一条消息时创建的,或者在进行adminutils.createtopic(…)调用时创建的。
e4yzc0pl2#
我找到了我的答案,那是因为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,现在运行良好。
2条答案
按热度按时间cgyqldqp1#
很可能是因为主题尚未创建。zookeeper中的主题节点是在broker处理指向该主题的第一条消息时创建的,或者在进行adminutils.createtopic(…)调用时创建的。
e4yzc0pl2#
我找到了我的答案,那是因为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,现在运行良好。