漫遊Kafka之過期數據清理

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

>>阅读原文<<