卡夫卡消费群体描述的结果在消费群体中并不存在

Question

我一直试图在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

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

感谢

Answer 1

此处使用bootstrap-server而非zookeeper

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

注意：这将只显示有关使用Java使用者API的使用者(非基于ZooKeeper的使用者(的信息

Answer 2

首先列出集群中的组：

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旧消费者(，那就是存储在ZK中旧的kafkaconsumer。你的卡夫卡消费者客户是哪个版本的？