kafka-consumer-group.sh --list --all-groups group信息获取不全

发表于: 2023-04-18   最后更新时间: 2023-04-18 18:45:25   542 游览

kafka在0.10.2和2.3.0版本中都存在以下问题;

  1. 通过kafka-consumer-group.sh --list --all-groups只能获取到较少的group成员信息;

  2. 通过调用ListConsumerGroupsResult类方法,可以获得全量的group成员信息;

为什么两者存在较大差别,如何才能让命令行输出全量信息?

  1. 后台无报错信息,正常调用;

  2. 有了解到--list会只输出活动状态group,再加入--all-groups时会输出所有的,但是未生效;

发表于 2023-04-18

这2个命令都是只能获取「活跃的」的消费者组,已经停止消费的消费者组是查询不到的哦。
所以有些kafka监控能查到是因为缓存(如KafkaOffsetMonitor),重启一下,已经停止的消费者组就消失了,只能查出活跃的了。

你的答案

查看kafka相关的其他问题或提一个您自己的问题