SpringKafka未遵循手动确认配置：消息自动提交问题排查求助

问题核心原因 #

Kafka消费者的enable.auto.commit属性默认开启，导致客户端自动定期提交offset，完全绕过了Spring Kafka的MANUAL手动确认机制。

问题分析 #

Spring Kafka的手动确认（MANUAL）模式仅在enable.auto.commit=false的前提下才会生效。如果这个属性为true（Kafka客户端默认值），消费者会按照auto.commit.interval.ms的默认周期（5秒）自动提交offset——即便你没有调用acknowledgment.acknowledge()，offset依然会被提交，消息不会重复消费，看起来就像“未确认但消息被消费”的情况。

从你的配置来看，application.yml中没有显式关闭enable.auto.commit，而如果你的ConsumerFactory没有手动设置这个属性为false，就会使用Kafka客户端的默认值true。

解决方案 #

1. 在application.yml中添加配置，关闭客户端自动提交：

spring:
  kafka:
    consumer:
      enable-auto-commit: false # 关键配置，关闭自动提交
      # 保留原有其他consumer配置...

2. 验证自定义容器工厂的有效性：
   确保你的@KafkaListener注解没有指定其他containerFactory——你的自定义工厂bean名称是kafkaListenerContainerFactory（Spring Kafka默认使用的容器工厂bean名称），默认会被自动使用。如果注解指定了其他工厂，需要调整为这个自定义工厂。

3. 确认监听器方法逻辑：
   检查onMessage方法确实没有调用acknowledgment.acknowledge()，如果不小心调用了该方法，也会触发offset提交。

补充说明 #

当enable.auto.commit=false且使用MANUAL模式时：

• 只有调用acknowledgment.acknowledge()才会提交当前批量消息的offset。
• 如果监听器方法抛出异常且未调用ack，offset不会提交，重启应用后会重新消费这批消息。
• Spring Kafka 2.3.x版本中，批量监听器的MANUAL模式行为与单条消息一致，必须手动触发确认。

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