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