今天和同事遇到一個非常有趣的問題，在Kafka監控頁面上可以看到該topic的消息會堆積到10萬條左右，然后再很快的消費完畢歸為0，然后又開始堆積到10萬條左右，時間間隔都是3分鍾。第一反應，反壓？ 但是反壓的也太整齊了吧。看了一眼代碼，哈哈，CheckPoint的時間間隔是3分鍾，而且是Exactly_Once的。
所以這3分鍾的延遲是必須付出的代價了，算不上問題
免責聲明！
本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。