记一次生产KAFKA数据 清理策略的调整
在网上查了好多资料,都说kafak默认清理是7天,但实际生产环境数据一直在堆积,没有清理。 然后在本地搭建了kafka集群,各种配置策略全部尝试了一下,最终确定要达到清理效果,如下几个配置必须有:
log.retention.hours
=72
log.roll.hours
=72
log.flush.interval.messages
=5000
log.cleanup.polict
=delete
log.segment.delete.delay.ms
=60000
log.cleanup.interval.mins
=10
delete.topic.enable
=true