Spring上下文无StreamBridge Bean，@Autowired注入失败求助

问题根源 #

Spring Cloud Stream 4.0.x（适配Spring Boot 3.x）调整了StreamBridge的自动注册逻辑：

• 旧版本（3.x及以下）中StreamBridge默认自动创建，但4.x开始，只有当项目启用函数式编程模型，或者显式配置开关时，才会实例化该Bean。这就是新版本注入失败的核心原因。

解决办法 #

方案1：添加函数绑定配置 #

在application.yml中声明至少一个函数绑定（哪怕是占位用的空函数），触发函数式模型初始化，从而自动创建StreamBridge：

spring:
  cloud:
Contrast:    stream:
      function:
        definition: placeholderFunction
      bindings:
        placeholderFunction-out-0:
          destination: switch_array_state

placeholderFunction仅作为占位，后续可替换为实际业务函数。

方案2：显式开启StreamBridge自动配置 #

如果不想使用函数式模型，直接通过配置强制启用StreamBridge：

spring:
  cloud:
    stream:
      stream-bridge:
        enabled: true

该配置是Spring Cloud Stream 4.x新增的，专门用于控制StreamBridge的自动注册。

方案3：手动注册Bean #

若以上配置不生效，可在配置类中手动实例化StreamBridge：

import org.springframework.cloud.stream.function.StreamBridge;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.integration.channel.DirectChannel;

@Configuration
public class StreamConfig {
    @Bean
    public StreamBridge streamBridge() {
        return new StreamBridge(new DirectChannel());
    }
}

优先推荐前两种配置方式，手动注册需确保Spring Integration相关依赖已正确引入。

额外检查项 #

• 确认pom.xml包含核心依赖：

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

• 核对application.yml中的Kafka地址、主题配置等是否正确，避免因配置错误导致自动配置逻辑未触发。

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