Spring Kafka手动提交偏移量失效：未调用acknowledge仍自动推进偏移量

可能原因及解决办法 #

• 异常被静默处理
  如果处理消息时的异常被全局异常处理器或try-catch块捕获但未重新抛出，Spring Kafka容器会默认判定消息处理成功，自动推进偏移量（即使未调用acknowledge()）。解决方式：确保处理失败时抛出异常，或在catch块中调用Acknowledgment.nack()，明确告知容器消息处理失败。

• @KafkaListener注解覆盖容器配置
  若在@KafkaListener注解中指定了ackMode属性，会覆盖代码中ContainerProperties设置的MANUAL_IMMEDIATE。检查注解配置，避免冲突：

  // 错误示例：注解指定自动提交模式，覆盖手动配置
  @KafkaListener(topics = "test", ackMode = "AUTO")
  // 正确示例：沿用容器配置的MANUAL_IMMEDIATE
  @KafkaListener(topics = "test")
  

• 存在额外偏移量提交逻辑
  排查代码中是否有其他地方调用KafkaConsumer.commitSync()或commitAsync()，这类操作会直接提交偏移量，绕过手动ack逻辑。确保仅在处理成功时调用acknowledge()，其他场景禁止主动提交。

• 错误处理器配置不当
  若使用SeekToCurrentErrorHandler或自定义错误处理器，需检查是否配置了重试耗尽后自动提交偏移量。默认的SeekToCurrentErrorHandler在重试次数耗尽后会提交偏移量并将消息转入死信队列，若需重复消费失败消息，需调整配置：

  // 配置无限重试（生产环境建议设置合理重试次数+死信策略）
  factory.setErrorHandler(new SeekToCurrentErrorHandler((record, ex) -> {
      // 自定义失败处理逻辑，如记录错误日志
  }, new FixedBackOff(1000L, Long.MAX_VALUE)));
  

• 框架版本bug
  部分旧版本（如2.3.x之前）的MANUAL_IMMEDIATE模式存在偏移量自动提交bug，建议升级到2.8.x及以上的稳定版本。

验证步骤 #

1. 开启Spring Kafka的debug日志，查看偏移量提交的触发来源。
2. 在消息处理方法中添加日志，确认是否进入失败分支、是否调用acknowledge()。
3. 暂停应用，通过Kafka命令行工具查看消费者组当前偏移量：

   kafka-consumer-groups.sh --bootstrap-server your-kafka-server:9092 --describe --group test
   

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