我真的很难理解/消费者/团体来自哪里 . 我有2个Kafka集群,我正在使用镜像制造商进行复制 . 复制工作正常,但有一块东西在逃避我 .

当我从Kafka(在这种情况下利用python)中提取消息时,我发现复制工作正常 .

但是我在zookeeper / consumers / group中什么也看不见,因此我无法用“bin / kafka-run-class.sh kafka.tools.ConsumerOffsetChecker”测试它 .

(这是说由于以下原因退出:org.apache.zookeeper.KeeperException $ NoNodeException:KeeperErrorCode = NoNode for / consumers / test-group / offsets /)

环境Kafka 2_8 OS Ubuntu 14.4 Zookeeper 3.4.5

好的,我走得更远 . 似乎问题是镜像制造商没有创建组ID . 当我从kafka工具中创建组ID时,我可以查看所有内容 . 因此,只剩下问题是为什么镜像制造商不会创建组ID .