Spring Cloud Stream能否同时使用@EnableBinding-@StreamListener与函数式风格？

可以同时使用两种风格，但需要调整配置来兼容，以下是具体的问题分析和解决方案：

问题原因 #

当项目中使用@EnableBinding注解时，Spring Cloud Stream默认会切换到基于注解的传统模式，该模式会抑制函数式组件的自动注册流程，导致你定义的output2函数式消费者无法被初始化，因此只有@StreamListener注解的消费者生效。

解决方案 #

通过添加配置参数启用混合模式，让两种风格的消费者都能被正确加载：

1. 启用函数式Bean扫描 #

在配置文件中添加spring.cloud.stream.function.scan: true，强制框架扫描并注册函数式Bean，即使存在@EnableBinding注解。

修改后的完整配置 #

spring:
  application:
    name: MixApplication
  cloud:
    stream:
      function:
        definition: output2
        scan: true  # 关键配置，开启函数式Bean扫描
      kafka:
        binder:
          brokers: localhost:9092
      bindings:
        output2-in-0:
          destination: test2
          group: "test"
          consumer:
            concurrency: 10
            max-attempts: 3
        output1:
          destination: test1
          group: "test"
          consumer:
            concurrency: 10
            max-attempts: 3

2. 代码无需额外修改 #

你的现有代码逻辑是正确的：

• @StreamListener(IncomingBinding.INPUT)会监听test1主题
• output2函数式Bean会监听test2主题

配置修改完成后，重启项目即可看到两种消费者都正常工作。

注意事项 #

• 确保所有绑定名称（如output1、output2-in-0）唯一，避免冲突
• 官方推荐优先使用函数式风格，旧版注解模式在后续版本中可能会被标记为废弃，建议逐步完成迁移

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