启动Kafka时,出现以下错误。
KeeperErrorCode = NoNode for /brokers/topics/test-topic/partitions
任何帮助都将被感谢。
发布于 2014-11-13 13:05:30
我找到了答案,这是因为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,现在它工作得很好。
发布于 2014-11-12 16:05:15
这很可能是因为主题尚未创建。Zookeeper中的主题节点是在broker处理到主题的第一条消息时创建的,或者,当AdminUtils.createTopic(...)打过电话了。
https://stackoverflow.com/questions/26879777
复制相似问题