kafka在0.10.2和2.3.0版本中都存在以下问题; 通过kafka-consumer-group.sh --list --all-groups只能获取到较少的group成员信息; 通过调用ListConsumerGroupsResult类方法,可以获得全量的group成员信息; 为什么两者存在较大差别,如何才能让命令行输出全量信息? 后台无报错信息,正常调用; 有了解到--list会只输出活动状态group,再加入--all-groups时会输出所有的,但是未生效;
这2个命令都是只能获取「活跃的」的消费者组,已经停止消费的消费者组是查询不到的哦。
所以有些kafka监控能查到是因为缓存(如KafkaOffsetMonitor),重启一下,已经停止的消费者组就消失了,只能查出活跃的了。
你的答案