kafka group删除问题

lq0317。 发表于: 2020-11-18   最后更新时间: 2020-11-18  

kafka_2.10-0.10.2.2 删除无用的group ,是不是直接通过kafka命令删除,而不是删除zk里面的consumers



您需要解锁本帖隐藏内容请: 点击这里
本帖隐藏的内容




上一条: 为什么关闭kafka之后,它会自动重启?
下一条: 如何设置kafka的内存大小

  • kafka 1.10 之后,group存储在名为__consumer_offsets的topic上了,默认会根据你的log.retention.hours(默认7天)进行删除。

    • 我的kafka版本2.4 配置文件中 log.retention.hours=8 broker没有设置参数
      topic级别 compression.type=producer,cleanup.policy=compact,segment.bytes=104857600,retention.bytes=10240000000
      经过8小时依然没有删除

        • 不应该是这个问题吧。就算改成delete,segement不会翻滚(满足segment.bytes=104857600,retention.bytes=10240000000才会翻滚),也删除不到。

            • __consumer_offsets 这个topic 默认50个分区,就是不晓得哪个时候清理。没有搞清楚。以后比如消费组超过了50个。会怎么处理