漫遊Kafka之過時數據清理

Kafka將數據持久化到了硬盤上，容許你配置必定的策略對數據清理，清理的策略有兩個，刪除和壓縮。spa 數據清理的方式 刪除 log.cleanup.policy=delete啓用刪除策略 直接刪除，刪除後的消息不可恢復。可配置如下兩個策略： 清理超過指定時間清理：   log.retention.hours=16 超過指定大小後，刪除舊的消息： log.retention.bytes=10737

>>阅读原文<<