溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
本篇文章給大家分享的是有關kafka一直在導致無法消費該怎么辦，小編覺得挺實用的，因此分享給大家學習，希望大家閱讀完這篇文章后可以有所收獲，話不多說，跟著小編一起來看看吧。
版本 : kafka_2.12-2.4.0kafka一直在rebalance，導致無法消費。comsumer報錯如下：
server端：
配置：
max.block.ms =60000
auto.commit.interval.ms =30000
enable.auto.commit =true
max.poll.interval.ms =500000
max.poll.records =300
session.timeout.ms =10000
heartbeat.interval.ms =3000
原因是：auto.commit.interval.ms 這個30秒不行，少于30秒，默認是5秒（如果提交失敗，則這個間隔時間的消息都會重新消費）。
引起的原因其實很簡單，kafka客戶端默認超時時間是30秒，如果消費者沒有響應，就會觸發重新平衡。
完善后的配置：
auto.commit.interval.ms=15000
rebalance.backoff.ms=2000
max.poll.interval.ms=300000
max.poll.records=300
其實Kafka這幾個配置，主要看業務流量采取相應的配置會好一點，并不是默認值就是最適合的。比如說業務處理數據的時間長、數據量太大這些都是業務場景。
以上就是kafka一直在導致無法消費該怎么辦，小編相信有部分知識點可能是我們日常工作會見到或用到的。希望你能通過這篇文章學到更多知識。更多詳情敬請關注億速云行業資訊頻道。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
