我写了一个 kafka 消费者和生产者,直到今天都运行良好。
今天早上,当我启动zookeeper和kafka时,我的消费者无法读取消息,我在zookeeper日志中发现了这一点:
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)
请您参考如下方法:
寻找 log.dirs 在您的 server.properties 文件中删除所有 Kafka 和 zookeeper 日志,然后尝试分别重新启动 zookeeper 和 Kafka。我遇到了同样的问题,这样做解决了它。