Spring Cloud Stream同消费组多消费者实现队列监听Bean冲突问题

AI 小北

2026-10-6

问题结论

开启allow-bean-definition-overriding: true不是该场景的最优解决方案，甚至存在潜在风险，不建议使用。

错误原因

你遇到的Bean重复注册错误，本质是同个应用内两个独立的Consumer绑定了相同的destination+消费组组合，Spring Cloud Stream会默认按照${destination}.${group}.errors.recoverer规则生成错误处理相关的单例Bean，相同的组合会触发Bean名冲突。
开启Bean覆盖相当于让框架直接用后注册的Bean覆盖先注册的，虽然暂时能用，但如果两个绑定的错误处理配置存在差异，会出现非预期的异常，Spring默认关闭该配置就是为了提前暴露配置冲突，不要随意开启。

正确实现方案

你的需求是同队列下多个消费者负载消费，单条消息仅被处理一次，不需要定义多个Consumer Bean，直接配置单Consumer的并发数即可，效果和你定义两个Consumer完全一致，且不会有配置冲突：

Java代码仅保留一个Consumer

@Component
public class MultipleFunctionsApplication {
    
    @Bean
    public Consumer<String> sink() {
        return message -> {         
            System.out.println(new Date() + "----------->>> Received message " + message);
        };
    }

}

配置文件调整为如下内容，通过concurrency参数指定消费并发数

spring:
  cloud:
    stream:
      bindings:
        sink-in-0:
          destination: rss-exchange
          group: requester
          consumer:
            concurrency: 2 # 需要多少个消费线程就配多少，可随意扩展
      function:
        definition: sink
  application:
    name: rss

该配置下框架会自动启动2个并发消费线程，同消费组内竞争消费，完全符合你要求的消息分发逻辑。