漫游Kafka之过期数据清理

2015年11月06日 15:40:56 阅读数：23054 Kafka将数据持久化到了硬盘上，允许你配置一定的策略对数据清理，清理的策略有两个，删除和压缩。 数据清理的方式 删除 log.cleanup.policy=delete启用删除策略 直接删除，删除后的消息不可恢复。可配置以下两个策略： 清理超过指定时间清理：   log.retention.hours=16 超过指定大小后，删除旧的消

>>阅读原文<<