consumer配置參數之max.poll.interval.ms


max.poll.interval.ms參數用於指定consumer兩次poll的最大時間間隔(默認5分鍾),如果超過了該間隔consumer client會主動向coordinator發起LeaveGroup請求,觸發rebalance;然后consumer重新發送JoinGroup請求

(1)實際應用中,消費到的數據處理時長不宜超過max.poll.interval.ms,否則會觸發rebalance

(2)如果處理消費到的數據耗時,可以嘗試通過減小max.poll.records的方式減小單次拉取的記錄數(默認是500條)


免責聲明!

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



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