Kafka消费群描述结果中消费群不存在

dbf7pr2w 于 2021-06-07 发布在 Kafka

关注(0)|答案(2)|浏览(612)

我一直在尝试用java编程运行以下脚本，它们大部分都能正常工作，但有些时候，这个错误不断出现：“用户组xyz不存在”。有人能解释一下为什么会发生这个错误，特别是当消费者组出现在--list脚本中时。

kafka/bin/kafka-consumer-groups.sh --zookeeper 
 192.xxx.x.xxx:2181 --describe -group TEST_CONSUMER

返回错误：

Error: The consumer group 'TEST_CONSUMER' does not exist.

但此脚本将消费者组列为活动组：

kafka/bin/kafka-consumer-groups.sh --zookeeper 192.xxx.x.xxx:2181 --list

那么，如果列出了它，为什么会返回一个错误，说明它不存在呢？同样与消费者群体相关——我运行这个脚本来获取滞后信息，因为我被告知，除非连接到每个消费者服务器或其他什么，否则不可能通过kafka1.0中的jmx度量来获取滞后信息。有人能核实一下吗？
谢谢

2条答案

使用 bootstrap-server 不是 zookeeper 在这里

bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my-group

注意：这将只显示有关使用java consumer api的使用者（非基于zookeeper的使用者）的信息。

首先列出群集中的组：

bin/kafka-consumer-groups.sh --bootstrap-server $IP_Address:9092 --list

然后描述你需要的小组：

bin/kafka-consumer-groups.sh --bootstrap-server $IP_Address:9092 --group $GROUPID --describe

如果这不起作用，我猜您描述的是一个在zk（akka old consumer）中的组，即存储在zk中的旧kafkaconsumer。哪个版本的Kafka消费客户机？