Spring Cloud @StreamListener未提供Acknowledgement头（已关自动提交）

看起来你遇到的问题是因为配置层级错误以及未明确设置手动确认模式导致的，我来一步步帮你解决：

问题根源分析 #

从你的报错信息和配置来看，有两个关键问题：

1. 你把Kafka特有的autoCommitOffset配置放在了通用的bindings.input.consumer下，而不是Kafka绑定专属的配置节点中，导致这个配置可能没有被正确应用到Kafka Consumer上。
2. 即使关闭了自动提交，Spring Cloud Stream默认的确认模式还是AUTO，这种模式下不会将Acknowledgment对象作为消息头传递，必须显式设置为MANUAL或MANUAL_IMMEDIATE。

修正后的配置 #

把你的YAML配置调整为以下结构，重点是将Kafka Consumer的配置移到spring.cloud.stream.kafka.bindings.input.consumer节点下，并添加acknowledgeMode配置：

spring:
  application:
    name: scheduler
  cloud:
    stream:
      kafka:
        binder:
          brokers: *kafka-broker*:9092
          zkNodes: *zookeeper*:2181
        # Kafka绑定专属的Consumer配置
        bindings:
          input:
            consumer:
              autoCommitOffset: false
              acknowledgeMode: MANUAL # 必须设置为手动确认模式
      # 通用绑定配置
      bindings:
        input:
          destination: scheduler
          contentType: application/json

监听器代码优化 #

你的监听器代码结构是正确的，建议在处理完业务逻辑后添加手动提交偏移量的逻辑，确保偏移量能正确提交：

@StreamListener(Sink.INPUT)
public void handleSchedulerMessage(@Payload SchedulerEvent event, 
                                   @Header(KafkaHeaders.ACKNOWLEDGMENT) Acknowledgment acknowledgment) {
    log.debug("[message={}]", event);
    // 业务处理逻辑
    log.debug("Event processed successfully [event={}]", event);
    
    // 手动提交偏移量
    if (acknowledgment != null) {
        acknowledgment.acknowledge();
    }
}

验证配置是否生效 #

启动应用后，查看日志中关于Kafka Consumer的配置输出，确认以下内容：

• auto.commit.offset被设置为false
• acknowledgeMode显示为MANUAL

如果看到这两个配置生效，那么消息头中就会携带kafka_acknowledgment，你的监听器就能正常获取到Acknowledgment对象了。

额外注意点 #

• 如果使用的是Spring Cloud Stream较旧的版本（比如Dalston或更早），可能需要调整配置键名，比如acknowledgeMode可能需要写成ack-mode，不过大部分新版本都支持驼峰式命名。
• 确保你的SchedulerEvent能被正确反序列化，否则可能会出现其他异常，不过从你的报错来看，反序列化是正常的，只是缺少头信息。

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