如何为单个Kafka主题/通道配置生产者重试参数？

当然可以针对单个主题或通道单独设置生产者重试参数，无需全局生效，具体配置方式如下：

• 通道级参数配置
  直接针对指定的通道（binding）配置Kafka生产者参数，该配置的优先级高于全局的binder配置。配置格式为：

  spring.cloud.stream.bindings.<你的通道名称>.producer.configuration.retries=3
  spring.cloud.stream.bindings.<你的通道名称>.producer.configuration.retry.backoff.ms=1000
  

  举个实际例子：如果你的输出通道名称为payment-notify-out，对应的配置就是：

  # 仅对payment-notify-out通道生效的重试配置
  spring.cloud.stream.bindings.payment-notify-out.producer.configuration.retries=3
  spring.cloud.stream.bindings.payment-notify-out.producer.configuration.retry.backoff.ms=1000
  

• 注意事项

  • 配置中的<你的通道名称>需要和代码里@Output/@Input注解定义的通道名一致，或者与spring.cloud.stream.bindings.<通道名称>.destination配置中指定的通道标识匹配。
  • 这种配置只会作用于目标通道，其他通道仍会沿用全局的binder配置（如果有设置的话）。

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