2017-02-25 70 views
0

我使用的动物园管理员无法提取采用了饲养员CLI

我使用的动物园管理员CLI来获取补偿对于给定的消费群体信息抵消了卡夫卡consumergroup信息。

下面是工作的罚款

Command: get /consumers/[ConsumerGroup]/offsets/[TopicName] 

o/p : 
0:1640002 
cZxid = 0x304ca036d 
ctime = Fri Dec 23 17:29:30 UTC 2016 
mZxid = 0x30af96e80 
mtime = Fri Feb 24 19:15:00 UTC 2017 
pZxid = 0x304ca036d 
cversion = 0 
dataVersion = 113179 
aclVersion = 0 
ephemeralOwner = 0x0 
dataLength = 9 
numChildren = 0 

但下面一个不工作

command: get /consumers/[Same_Consumer_Group]/offsets/[Same_Topic_Name]/0 

o/p:Node does not exist: /consumers/[Same_Consumer_Group]/offsets/[Same_Topic_Name]/0 

所以,当我试图让使用PARTITION_ID那么它不工作补偿信息。

注意第一个命令显示0:1640002因此,这意味着偏移量是1640002在分区0 请帮我解决这个问题

回答

1

动物园管理员基本上是一棵树,numChildren的= 0说

/consumers/[ConsumerGroup]/offsets/[TopicName] 

是一个叶节点,因此如你所期望的那样,当你试图获得它的(不存在的)子节点时,你会得到一个错误。

https://cwiki.apache.org/confluence/display/KAFKA/Kafka+data+structures+in+Zookeeper从卡夫卡0.8偏移量存储在动物园管理员的方式是

/consumers/[ConsumerGroup]/offsets/[TopicName] 

不包含任何数据本身,而是偏移可以在子节点中找到

/consumers/[ConsumerGroup]/offsets/[TopicName]/[Partition] 

然而,由于你对我的假设是,你所要做的就是你要么使用一些老版本的卡夫卡,要么使用(对于某些版本的卡夫卡)用于单个分区主题,树中的额外级别isn没有创造。

但是,在我看来,所有这些都不应该关注你。 看看你发布的输出,看起来你有一个主题有1个分区,该分区内该特定用户组的偏移量为1640002.这就是你需要的所有偏移量信息,不是?

现在,如果话题有多个分区,那么可能会发生一些奇怪的事情。

如果您认为您仍然有问题,请在评论中发布您的Kafka和Zookeeper版本以及主题中的分区数量。

让我知道这是否有帮助。

+0

谢谢@ ossu54。是的,我有一个分区主题。我想为我的消费者群设置一个新的抵消额。最后我能够做到。使用下面的命令get/consumers/[ConsumerGroup] /偏移量/ [TopicName] 0:。最初我试图得到/消费者/ [ConsumerGroup] /偏移量/ [TopicName]/0 哪些不起作用 –