Zookeeper&Kafka错误KeeperErrorCode = NodeExists

Question

我已经写了一个kafka consumer,producer直到今天这个工作正常.今天早上,当我开始zooekeeper和kafka我的消费者没有成功读取消息,并在Zookeeper log我读了这个错误

INFO Got user-level KeeperException when processing sessionid:0x151c41e62e10000 type:create cxid:0x2a zxid:0x1e txntype:-1 reqpath:n/a Error Path:/brokers/ids Error:KeeperErrorCode = NodeExists for /brokers/ids (org.apache.zookeeper.server.PrepRequestProcessor)

你可以帮帮我吗？在短短几天内可能会发生什么变化？我不明白.非常感谢你.

Answer 1

在 server.properties 文件中查找log.dirs并从其中删除所有 Kafka 和 Zookeeper 日志，然后尝试分别重新启动 Zookeeper 和 Kafka。我面临着同样的问题，并这样做解决了它。