錯誤原因:
kafka設置了自動提交,但在規定的提交時間之內卻沒有處理完消息,導致消息自動提交出錯,這樣還會引發一個問題,就是當提交的消息不成功,kafka有重試機制,這樣就會重新消費該消息,但消費又不成功,這樣循環,會導致后面的消息堆積過多。
解決辦法:
1、修改提交方式,改為手動提交(默認為自動提交);
2、根據實際情況,修改提交時間(默認時間單位為毫秒,5000毫秒);
3、根據實際業務,修改代碼,降低消息處理時間(可以使用線程池異步處理消息,但需要標記消息是否處理成功,對處理不成功的消息需要重新發送消息,重新消費)。
————————————————
原文鏈接:https://blog.csdn.net/xionglangs/article/details/81507617