kafka數據清理

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

>>阅读原文<<