漫遊Kafka之過期數據清理

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