如何在Spring Cloud Stream函数中为输出消息配置自定义header值

API 探路者

2026-10-6

错误原因分析

你之前的配置不生效主要有三个问题：

input-header-mapping-expression是消费者端用于映射输入消息头的配置，你当前是生产者（Supplier）要给输出消息加头，用错了配置项
配置层级错误：消息头提取配置不属于spring.cloud.function.configuration，应该放在Spring Cloud Stream的生产者绑定配置下
SpEL写法错误：不需要加spel.function.expression=前缀，直接写表达式内容即可

正确配置方案

你使用的是返回Flux<PayLoad>的Supplier，直接用下面的application.yml配置即可实现从Payload字段提取消息头：

spring:
  application:
    name: messages
  cloud:
    function:
      definition: sendMessage;consumeMessage
    stream:
      bindings:
        # Supplier的输出绑定命名规则为 函数名-out-序号，默认序号从0开始
        sendMessage-out-0:
          destination: 你的目标消息队列/Topic名称
          producer:
            header-enricher:
              headers:
                # 直接写SpEL表达式从输出的payload中提取字段
                header1:
                  expression: payload.header1
                header2:
                  expression: payload.header2

补充说明

如果你用的是返回Flux<Message<PayLoad>>的版本，也可以直接在代码里构造Message时手动设置头，不需要额外配置：

@Bean
Supplier<Flux<Message<PayLoad>>> sendMessage() {
    return () -> getMessageSink().asFlux()
            .map(payLoad -> MessageBuilder.withPayload(payLoad)
                    .setHeader("header1", payLoad.header1)
                    .setHeader("header2", payLoad.header2)
                    .build())
            .log();
}