Kafka使用log.retention.hours改變消息端的消息保存時間


數據存儲的最大時間超過這個時間會根據log.cleanup.policy設置的策略處理數據,也就是消費端能夠多久去消費數據
log.retention.byteslog.retention.hours任意一個達到要求,都會執行刪除,會被topic創建時的指定參數覆蓋。
server.properties里設置

 
        
  1. #Kafka的消息只保存一個小時
  2. log.retention.hours=1
 
        
  1. #Kafka的消息只保留1024個字節
  2. log.retention.bytes=1024


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM