漫游Kafka之过时数据清理

Kafka将数据持久化到了硬盘上，容许你配置必定的策略对数据清理，清理的策略有两个，删除和压缩。spa 数据清理的方式 删除 log.cleanup.policy=delete启用删除策略 直接删除，删除后的消息不可恢复。可配置如下两个策略： 清理超过指定时间清理：   log.retention.hours=16 超过指定大小后，删除旧的消息： log.retention.bytes=10737

>>阅读原文<<