Spring Kafka批量消费者处理超max.poll.interval.ms未触发重均衡问题

你没有观测到预期的重均衡行为，核心是存在两处配置不生效的错误，以及观测逻辑的疏漏：

• 消费者配置完全未生效：你定义的myBatchConsumerConfigs方法声明了返回Map<String, Object>类型，但方法末尾没有return configs;语句，最终传入消费者工厂的配置是空值，你设置的MAX_POLL_INTERVAL_MS_CONFIG=300000根本没有加载，实际运行时使用的是Kafka消费者的默认配置。
• 自定义监听容器工厂未生效：你声明的容器工厂Bean的方法名为kafkaListenerContainerFactory，默认Bean名和方法名一致，但你在@KafkaListener注解中指定的containerFactory = "myBatchConsumerContainerFactory"，两者名称完全不匹配，最终你的监听器使用的是Spring Kafka自动装配的默认容器工厂，你自定义的批量模式、重均衡监听器、提交模式等配置全部没有生效。
• 观测逻辑存在疏漏：你注释了重均衡监听器的日志代码，仅依赖System.out输出，很容易因为控制台输出缓冲、日志级别限制导致你看不到重均衡触发的回调输出，无法判断实际是否发生了重均衡。

• 补全myBatchConsumerConfigs方法的返回逻辑，在方法末尾添加return configs;，保证自定义消费者配置可以被正确加载。
• 统一容器工厂的命名，要么修改@Bean方法名为myBatchConsumerContainerFactory，要么修改@KafkaListener的containerFactory属性值为kafkaListenerContainerFactory，保证自定义的容器工厂配置可以被监听器使用。
• 优化测试逻辑：你当前是对每条消息单独休眠400秒，如果单次poll拉取到多条消息，总处理时长会远超预期，建议把休眠逻辑放到遍历消费记录的外层，仅做一次400秒休眠即可，缩短测试验证的周期。
• 开启Kafka客户端调试日志：在日志配置中将org.apache.kafka.clients.consumer包的日志级别调整为DEBUG，即可直接看到消费者心跳超时、被踢出消费组、重均衡触发的全流程日志，无需完全依赖自定义监听器的输出。
• 验证版本兼容性：Spring Kafka 2.2.7.RELEASE对应的原生Kafka客户端版本为2.0.1，需要保证你的Kafka服务端版本不低于0.11.0.0，否则max.poll.interval.ms相关的超时踢出逻辑本身就不支持。

额外提示：你当前配置的AckMode.BATCH+手动提交模式下，重均衡触发后，未提交的这批消息会被新分配到对应分区的消费者重新消费，会出现重复消费的情况，这是正常的预期行为。

内容的提问来源于stack exchange，提问作者Raj