删除不活跃的consumergroup 1、监控各个consumergroup的消费滞后信息,发现程序停止的consumergroup还存在consumergroup的list中,导致能被监控到。就是这个消费组中没有人再去消费了,能够主动删除掉这个消费组。 2、之前的也发现清除过,难道是这个比较新,Kafka有时间过期规则?
会
消费者组默认存储在
topic
为__consumer_offsets
中,所以它也是一个topic
,只是存储的是消费者组的offset的,规则也跟所有的topic一样,所以,默认情况下,如果不使用,默认也是7
天会清理(log.retention.hours)。当然,也受日志压缩的策略所影响。参数来自:Kafka Broker配置
你可以手动清理:删除kafka消费者组
你的答案