kafka重複消費問題

問題描述 採用kafka讀取消息進行處理時，consumer會重複讀取afka隊列中的數據。web 問題緣由 kafka的consumer消費數據時首先會從broker裏讀取一批消息數據進行處理，處理完成後再提交offset。而咱們項目中的consumer消費能力比較低，致使取出的一批數據在session.timeout.ms時間內沒有處理完成，自動提交offset失敗，而後kafka會從新分配p

>>阅读原文<<