apache-zookeeper - Zookeeper 具有 KeeperException 但 Kafka 能够创建主题并生产/消费

Question

我最近在单节点 CDH 5 设置上设置了 Kafka，目的是在移动到真正的集群之前在单节点上使用它。最初，我只是用 kafka 服务器启动了 zookeeper 服务器，一切都很好。我可以看到zookeeper在2181上运行，而Kafka在9092上运行。然后我创建了一个主题，启动了消费者和生产者，消费者可以看到生产者发送的消息。

我脸上洋溢着幸福，移到带有动物园管理员日志的选项卡上，看到了:

[2015-05-27 16:46:07,016] INFO Got user-level KeeperException when processing sessionid:0x14d97bf0a020002 type:create cxid:0x2 zxid:0x1f txntype:-1 reqpath:n/a Error Path:/consumers/test-consumer-group/ids Error:KeeperErrorCode = NoNode for /consumers/test-consumer-group/ids (org.apache.zookeeper.server.PrepRequestProcessor)
[2015-05-27 16:46:07,021] INFO Got user-level KeeperException when processing sessionid:0x14d97bf0a020002 type:create cxid:0x3 zxid:0x20 txntype:-1 reqpath:n/a Error Path:/consumers/test-consumer-group Error:KeeperErrorCode = NoNode for /consumers/test-consumer-group (org.apache.zookeeper.server.PrepRequestProcessor)
[2015-05-27 16:46:07,306] INFO Got user-level KeeperException when processing sessionid:0x14d97bf0a020002 type:create cxid:0x19 zxid:0x24 txntype:-1 reqpath:n/a Error Path:/consumers/test-consumer-group/owners/test Error:KeeperErrorCode = NoNode for /consumers/test-consumer-group/owners/test (org.apache.zookeeper.server.PrepRequestProcessor)
[2015-05-27 16:46:07,307] INFO Got user-level KeeperException when processing sessionid:0x14d97bf0a020002 type:create cxid:0x1a zxid:0x25 txntype:-1 reqpath:n/a Error Path:/consumers/test-consumer-group/owners Error:KeeperErrorCode = NoNode for /consumers/test-consumer-group/owners (org.apache.zookeeper.server.PrepRequestProcessor)
[2015-05-27 16:47:06,961] INFO Got user-level KeeperException when processing sessionid:0x14d97bf0a020002 type:setData cxid:0x24 zxid:0x29 txntype:-1 reqpath:n/a Error Path:/consumers/test-consumer-group/offsets/test/0 Error:KeeperErrorCode = NoNode for /consumers/test-consumer-group/offsets/test/0 (org.apache.zookeeper.server.PrepRequestProcessor)
[2015-05-27 16:47:06,963] INFO Got user-level KeeperException when processing sessionid:0x14d97bf0a020002 type:create cxid:0x25 zxid:0x2a txntype:-1 reqpath:n/a Error Path:/consumers/test-consumer-group/offsets Error:KeeperErrorCode = NoNode for /consumers/test-consumer-group/offsets (org.apache.zookeeper.server.PrepRequestProcessor)

看起来 zookeeper 无法为 找到节点。 . .东西。但是，如果是这样，为什么我的所有命令都有效？我能够创建一个主题，然后为它生成一些数据，同时订阅它的消费者也获取数据？

如果有帮助，我的 zookeeper 版本是 3.4.6，我的 Kafka 版本是 0.8.2.1。哦，路径/tmp/zookeeper 存在。

Answer 1

我遇到了同样的问题。

Exiting due to: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/test-group/offsets/packets/0.

我解决了我的问题。

确保您的 zookeeper 和 kafka broker 正在运行。

是的，您可以创建主题，生产者/消费者将起作用。

要解决该错误，您必须拥有一个订阅该主题的消费者组。

在您的情况下，它将是消费者组 test-consumer-group 的消费者。并订阅主题 Test