错误原因:
kafka设置了自动提交,但在规定的提交时间之内却没有处理完消息,导致消息自动提交出错,这样还会引发一个问题,就是当提交的消息不成功,kafka有重试机制,这样就会重新消费该消息,但消费又不成功,这样循环,会导致后面的消息堆积过多。
解决办法:
1、修改提交方式,改为手动提交(默认为自动提交);
2、根据实际情况,修改提交时间(默认时间单位为毫秒,5000毫秒);
3、根据实际业务,修改代码,降低消息处理时间(可以使用线程池异步处理消息,但需要标记消息是否处理成功,对处理不成功的消息需要重新发送消息,重新消费)。
————————————————
原文链接:https://blog.csdn.net/xionglangs/article/details/81507617