漫游Kafka之过期数据清理

2019独角兽企业重金招聘Python工程师标准>>> Kafka将数据持久化到了硬盘上，允许你配置一定的策略对数据清理，清理的策略有两个，删除和压缩。 数据清理的方式 删除 log.cleanup.policy=delete启用删除策略 直接删除，删除后的消息不可恢复。可配置以下两个策略： 清理超过指定时间清理：   log.retention.hours=16 超过指定大小后，删除旧的消息：

>>阅读原文<<