kafka 消费 报 Commit cannot be completed since the group has already rebalanced and assigned the partitions to ano


错误原因:

        kafka设置了自动提交,但在规定的提交时间之内却没有处理完消息,导致消息自动提交出错,这样还会引发一个问题,就是当提交的消息不成功,kafka有重试机制,这样就会重新消费该消息,但消费又不成功,这样循环,会导致后面的消息堆积过多。

解决办法:

        1、修改提交方式,改为手动提交(默认为自动提交);

        2、根据实际情况,修改提交时间(默认时间单位为毫秒,5000毫秒);

        3、根据实际业务,修改代码,降低消息处理时间(可以使用线程池异步处理消息,但需要标记消息是否处理成功,对处理不成功的消息需要重新发送消息,重新消费)。
————————————————

原文链接:https://blog.csdn.net/xionglangs/article/details/81507617


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM