多@StreamListener应用转多Consumer实现遇Bean未注册问题求助

我正尝试将使用已弃用@StreamListener注解的应用转换为推荐的Consumer函数式实现。单主题监听的应用转换过程很顺利，但在将两个分别监听不同主题的@StreamListener转换为Consumer Bean时，发现两个Bean均未注册，将Bean拆分到不同类中也没有效果。

绑定配置 #

spring.cloud.stream.bindings.dataExtractionMessageConsumerTopic1-in-0.destination=data_extractor_1
spring.cloud.stream.bindings.dataExtractionMessageConsumerTopic1-in-0.group=data_extractor_1

spring.cloud.stream.bindings.dataExtractionMessageConsumerTopic2-in-0.destination=data_extractor_2
spring.cloud.stream.bindings.dataExtractionMessageConsumerTopic2-in-0.group=data_extractor_2

定义的Consumer Bean #

@Bean
public Consumer<DataExtractionMessage> dataExtractionMessageConsumerTopic1() {
    return incomingMessage -> {
        log.info("dataExtractionMessageConsumerTopic1 received {}", incomingMessage);
    };
}

@Bean
public Consumer<DataExtractionMessage> dataExtractionMessageConsumerTopic2() {
    return incomingMessage -> {
        log.info("dataExtractionMessageConsumerTopic2 received {}", incomingMessage);
    };
}

请问是否存在单应用仅能绑定一个Consumer的限制？

Spring Cloud Stream 并没有单应用只能绑定一个Consumer的限制，多Consumer Bean的场景是完全支持的。你遇到的问题大概率是配置或Bean加载的问题，可从以下几个方向排查：

• 开启函数式Bean定义配置：必须在配置文件中添加spring.cloud.stream.function.definition=dataExtractionMessageConsumerTopic1;dataExtractionMessageConsumerTopic2，这个配置用来指定Spring Cloud Stream需要加载的函数式Bean列表，未配置的话框架不会自动识别所有Consumer Bean。
• 确认Bean的扫描范围：定义Consumer Bean的类需要被@Configuration或@Component注解标记，且该类所在的包要在Spring的组件扫描路径之内，否则Bean无法被容器加载。
• 核对配置命名一致性：绑定配置中的dataExtractionMessageConsumerTopic1-in-0必须和对应的Consumer Bean名称完全一致，注意大小写敏感，避免拼写错误。
• 检查依赖版本兼容性：如果使用的Spring Cloud Stream版本较低，可能存在函数式多Consumer的兼容问题，建议升级到3.x及以上的稳定版本（函数式API在3.0版本后成为官方推荐的实现方式）。

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