數據存儲的最大時間超過這個時間會根據log.cleanup.policy設置的策略處理數據,也就是消費端能夠多久去消費數據
log.retention.bytes和log.retention.hours任意一個達到要求,都會執行刪除,會被topic創建時的指定參數覆蓋。
在server.properties里設置
- #Kafka的消息只保存一個小時
- log.retention.hours=1
- #Kafka的消息只保留1024個字節
- log.retention.bytes=1024
數據存儲的最大時間超過這個時間會根據log.cleanup.policy設置的策略處理數據,也就是消費端能夠多久去消費數據
log.retention.bytes和log.retention.hours任意一個達到要求,都會執行刪除,會被topic創建時的指定參數覆蓋。
在server.properties里設置
本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。