我用spring-kafka 2.2.4实现和你类似的功能,设置enable-auto-commit = false,且不做offset提交,但是跑了一段时间出现消费者停止了消费,有看到日志 org.apache.kafka.clients.FetchSessionHandler:394 - [Consumer clientId=consumer-2, groupId=ctk_rk_ad_report_high] Node 2 sent an invalid full fetch response with omitted=,不知道你有没有遇到过类似的情况
感谢! 是不是可以这样理解,consumer poll 一堆消息之后,每条消息都直接扔给其他线程去处理,扔完之后,直接更新 redis 的 offset(相当于是提交了offset),相当于消费 和 业务逻辑通过线程分开了