我已经写了一个Kafka消费者和生产者，工作良好，直到今天。今天早上，当我启动zookeeper和kafka时，我的消费者无法阅读消息，我在zookeeper日志中发现：
INFO Got user-level KeeperException when processing sessionid:0x151c41e62e10000type:create cxid:0x2a zxid:0x1e txntype:-1 reqpath:n/aError Path:/brokers/idsError:KeeperErrorCode = NodeExists for /brokers/ids(org.apache.zookeeper.server.PrepRequestProcessor)
4条答案
按热度按时间niwlg2el1#
转到kafka根目录并查找日志文件。清除所有日志。例如：假设您的Kafka安装在下载文件夹中：
它将解决这个问题。
amrnrhlw2#
根据汇合处https://groups.google.com/forum/#!2016/10/08主题/汇合平台/h0geikèii1e
这些不是错误，您可以看到日志级别是info。它只是记录Kafka试图创建一个已经存在的节点。Kafka的行为完全正常，没什么好担心的。
是否存在与消息相关的实际问题，或者是否一切正常？
ycggw6v23#
在server.properties文件中查找log.dirs并从中删除所有kafka和zookeeper日志，然后分别尝试重新启动zookeeper和kafka。我也面临同样的问题，这样做就解决了。
mbjcgjjk4#
我的Kafka在Windows7上运行时出现了这个错误。我认为这个例外不是问题，因为它只是信息级别。只要确保经纪人还在运行。即使有这个错误，我仍然可以：
创建并列出主题
kafka-topics.bat.使用主题
kafka-console-consumer.bat.以编程方式发送消息
producer.send(new ProducerRecord<String, String>("topic", "hello")).get().