Spring Cloud Stream 3.1.4升级后StreamBridge自动注入失败如何解决

问题根因 #

Spring Cloud Stream 3.1.4版本调整了StreamBridge的自动装配规则：只有当项目中存在明确的绑定器（Binder）依赖、或已配置有效函数绑定的场景下，才会自动注册StreamBridge类型的Bean，3.1.3版本的装配条件更宽松，因此升级后出现找不到Bean的报错。

可选用的解决方案 #

方案1：添加对应消息中间件的绑定器依赖（推荐） #

当前pom.xml仅引入了Spring Cloud Stream核心依赖，缺少具体消息中间件的绑定器实现，这是最常见的触发原因。根据你使用的消息组件添加对应依赖即可：

• 若使用RabbitMQ，添加依赖：

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-stream-binder-rabbit</artifactId>
</dependency>

• 若使用Kafka，添加依赖：

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-stream-binder-kafka</artifactId>
</dependency>

• 若使用Solace，添加依赖：

<dependency>
    <groupId>com.solace.spring.cloud</groupId>
    <artifactId>spring-cloud-stream-binder-solace</artifactId>
</dependency>

方案2：补充函数绑定配置 #

你在代码中定义了uppercase函数Bean，但未在配置中声明需要绑定的函数，也会导致自动装配不触发。在application.yml/application.properties中添加如下配置：

spring:
  cloud:
    function:
      definition: uppercase

方案3：手动注册StreamBridge Bean（仅测试场景使用） #

如果暂时不需要对接实际消息中间件，仅做本地测试，可以手动在配置类中注册StreamBridge的Bean：

import org.springframework.cloud.stream.function.StreamBridge;
import org.springframework.cloud.stream.binder.test.TestChannelBinderConfiguration;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Import;
import org.springframework.context.annotation.Configuration;

@Configuration
@Import(TestChannelBinderConfiguration.class)
public class StreamBridgeConfig {
    @Bean
    public StreamBridge streamBridge() {
        return TestChannelBinderConfiguration.getApplicationContext().getBean(StreamBridge.class);
    }
}

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