kafka9重複消費問題解決

kafka9重複消費問題解決java 背景：以前用的kafka客戶端版本是0.8，近期升級了kafka客戶端的版本，寫了新的消費者和生產者的代碼，在本地測試沒有問題，能夠正常消費與生產。但最近的項目中使用了新版的代碼，當數據量較大時會出現重複消費的問題。現將問題的排除與解決過程記錄下來，避免再次踩坑。apache 問題發現：因爲ConsumerRecord對象能夠獲取到當前消息的分區與偏移量，故在

>>阅读原文<<