最近遇到一个springboot整合kafka设置手动提交不生效的问题，后来发现是自己的方法不对，走了一些弯路，这里记录一下。 环境准备 spring boot 2.1.6.RELEASE 本地zk, 单节点kafka，版本是kafka_2.11-2.2.0 新建一个topic，topic名是 spring-kafka-demo4，如下： {代码...} topic设置了两个分区。 问题描述 消费者工程的...

kafka的服务端在超过了 max.poll.interval.ms 时间内没有收到某个消费者的心跳，认为该消费者已经“挂了”，所以进行了topic的分区所有权“再均衡”。