Spring Cloud Stream 4.x迁移：预创建输出绑定失效问题求助

问题场景 #

把基于废弃注解的Spring Cloud Stream应用迁移到4.x函数式风格，原用RabbitMQ做消息中间件。迁移后用StreamBridge发送数据，需要保留框架自动创建主题、生产者配置等特性，所以按文档配置了spring.cloud.stream.output-bindings来预创建输出绑定，但配置没生效。

排查后发现，内部库的部分Function Bean被FunctionCatalog.lookup方法识别，导致主题预创建步骤被跳过，调整spring.cloud.stream.function.autodetect配置也解决不了问题。

解决方案 #

1. 禁用自动检测所有Function Bean #

通过spring.cloud.stream.function.definition设为空字符串，强制框架不加载自动检测到的Function Bean，触发输出绑定的预创建逻辑：

spring:
  cloud:
    stream:
      output-bindings: test
      function:
        definition: ""
      bindings:
        test-out-0:
          contentType: application/json
      rabbit:
        bindings:
          test-out-0:
            producer:
              delivery-mode: non-persistent
              transacted: true

2. 排除特定冲突的Function Bean #

如果要保留部分业务Function Bean，只排除内部库中引发冲突的函数，用spring.cloud.stream.function.exclude指定要排除的Bean名称（多个用逗号分隔）：

spring:
  cloud:
    stream:
      output-bindings: test
      function:
        exclude: "internalFunc1,internalFunc2" # 替换为实际的内部函数Bean名称
      bindings:
        test-out-0:
          contentType: application/json
      rabbit:
        bindings:
          test-out-0:
            producer:
              delivery-mode: non-persistent
              transacted: true

3. 自定义FunctionCatalog加载逻辑 #

如果上述配置方式无效，可以自定义FunctionCustomizer调整函数加载逻辑，避免干扰输出绑定预创建：

@Configuration
public class StreamCustomConfig {

    @Bean
    public FunctionCustomizer functionCustomizer() {
        return (context, functionName, function) -> {
            // 这里添加逻辑，过滤掉不需要的内部函数Bean
            // 或者调整函数加载优先级，确保输出绑定预创建先执行
        };
    }
}

原理说明 #

Spring Cloud Stream 4.x里，当框架检测到容器中存在Function Bean时，会优先处理函数式绑定流程，跳过output-bindings指定的输出绑定预创建逻辑。通过显式控制Function Bean的加载（禁用或排除），能让框架回到预创建输出绑定的流程，使配置生效。

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