Spring Cloud Stream Kafka如何在通道级别配置生产者的acks=1与max.in.flight.requests.per.connection=10属性

嗨，我懂你现在的困扰——明明配置了通道级的生产者属性，但日志里还是显示全局binder的默认值对吧？问题出在你的YAML配置结构和路径上，咱们来一步步修正：

首先得明确一个核心点：Kafka专属的生产者配置必须嵌套在spring.cloud.stream.kafka.bindings.<通道名>.producer.configuration下，而非通用的spring.cloud.stream.bindings.<通道名>.producer.configuration里。另外你当前的YAML缩进有错误，导致通道级配置没被正确识别。

正确的配置示例 #

spring:
  cloud:
    stream:
      bindings:
        channel_out:
          destination: topicname
          binder: kafka
      kafka:
        binder:
          # 全局binder级默认生产者配置，通道级配置会覆盖这些值
          producer-properties:
            acks: all
            max.in.flight.requests.per.connection: 1
            retries: 10
        bindings:
          channel_out:
            producer:
              configuration:
                # 此处配置会覆盖全局binder的对应属性
                acks: 1
                max.in.flight.requests.per.connection: 50

关键细节说明 #

• 注意YAML缩进层级：kafka.bindings和kafka.binder是同级节点，都隶属于spring.cloud.stream.kafka，不能把bindings嵌套进binder里面。
• 通道级的configuration节点专门用来配置Kafka原生生产者属性，这里设置的参数优先级高于全局binder配置，会直接覆盖默认值。
• 你之前尝试的spring.cloud.stream.bindings.<channel-name>.producer.configuration是通用通道配置路径，适用于所有类型的binder，但Kafka特定属性建议放在kafka子节点下的对应路径，这样更明确也不容易出错。

验证方法 #

重启服务后，查看o.a.k.clients.producer.ProducerConfig的日志输出，你应该能看到对应的属性已经变成通道级别设置的值（比如acks=1、max.in.flight.requests.per.connection=50），而非全局binder的默认值了。

备注：内容来源于stack exchange，提问作者Mike Reddington