这2个命令都是只能获取「活跃的」的消费者组,已经停止消费的消费者组是查询不到的哦。
所以有些kafka监控能查到是因为缓存(如KafkaOffsetMonitor),重启一下,已经停止的消费者组就消失了,只能查出活跃的了。
你消费者还在,是无法强制删除的呀?既然你要删除这个组,得先把消费者全停了的。
1、数据显示异常,但Lag是处于波动状态,有消费;
2、集群重启后,该现象依旧存在,有没有什么好的办法可以强制删除该组吗。
怀疑你现在的集群不健康。
你这个数据明显是不正常的,虽然有成员,但是其实都没有被分配消费。
有两点疑问:
为什么通过kafka-consumer-group.sh --all-groups/--members/--state
查看数据存在前后不一致,--all-groups
是没有获取到对应的consumer
信息的,--members
反而有数据;
看--member -verbose
中的assignment
是空的,也是否意味着client-id
是没有实际消费kafka的partitons的;