kafka producer如何優化打入速度?


  • 增加線程

  • 提高 batch.size

  • 增加更多 producer 實例

  • 增加 partition 數

  • 設置 acks=-1 時,如果延遲增大:可以增大 num.replica.fetchers(follower 同步數據的線程數)來調解;

  • 跨數據中心的傳輸:增加 socket 緩沖區設置以及 OS tcp 緩沖區設置。


  • 免責聲明!

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



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