首页 文章

Zookeeper有KeeperException但Kafka能够创建主题并生成/消费

提问于
浏览
11

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

幸福地在我脸上,我移动到带有zookeeper日志的标签,看到了这个:

[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存在 .

1 回答

  • 2

    我正在解决同样的问题

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

    我解决了问题,你确保你的zookeeper和kafka经纪人正在运行,是的,你可以创建主题和 生产环境 者消费者将工作 . 要解决错误,必须让具有消费者群体的消费者和该消费者群体使用该主题

    在你的情况下,它将成为消费者群体 test-consumer-group 的消费者,并被抄袭主题 Test

相关问题