kafka会主动删除不活跃的consumergroup吗?

起风了 发表于: 2021-09-15   最后更新时间: 2021-09-15 17:32:13   4,393 游览

删除不活跃的consumergroup

1、监控各个consumergroup的消费滞后信息,发现程序停止的consumergroup还存在consumergroup的list中,导致能被监控到。就是这个消费组中没有人再去消费了,能够主动删除掉这个消费组。

2、之前的也发现清除过,难道是这个比较新,Kafka有时间过期规则?

发表于 2021-09-15
添加评论

消费者组默认存储在topic__consumer_offsets中,所以它也是一个topic,只是存储的是消费者组的offset的,规则也跟所有的topic一样,所以,默认情况下,如果不使用,默认也是7天会清理(log.retention.hours)。当然,也受日志压缩的策略所影响。

参数来自:Kafka Broker配置

你可以手动清理:删除kafka消费者组

你的答案

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