Spring Cloud Stream多模块路由函数输出绑定禁用方案咨询

针对你遇到的路由函数自动创建未使用的*-out-0输出绑定及对应Topic的问题，结合spring-cloud-stream 3.2.4版本特性，可通过以下几种方式直接禁用这类无用绑定：

1. 显式将路由函数声明为纯Consumer类型 #

默认情况下，RoutingFunction会被识别为带输入输出的Function类型，即便路由目标是Consumer，框架仍会自动生成输出绑定。你可以在定义路由Bean时，直接返回Consumer<Message<?>>类型，而非Function：

@Bean
public Consumer<Message<?>> firstModuleRouter(ConsumerMessageRoutingCallback routingCallback) {
    return new RoutingFunction(routingCallback);
}

这样框架会识别该Bean为纯消费者，不会生成对应的输出绑定。

2. 在配置文件中直接禁用指定输出绑定 #

如果无法修改Bean定义，可通过配置显式关闭无用的输出绑定：

# 禁用firstModuleRouter的输出绑定
spring.cloud.stream.bindings.firstModuleRouter-out-0.enabled=false
# 禁用secondModuleRouter的输出绑定
spring.cloud.stream.bindings.secondModuleRouter-out-0.enabled=false

该配置会直接阻止框架创建对应的输出绑定及Topic，是比指向原有Topic更彻底的解决方案。

3. 自定义绑定接口，仅声明输入绑定 #

通过自定义Binding接口，只定义输入通道，让路由函数绑定到该输入，避免自动生成输出：

public interface RouterBindings {
    String FIRST_MODULE_INPUT = "firstModuleRouter-in-0";

    @Input(FIRST_MODULE_INPUT)
    SubscribableChannel firstModuleInput();
}

然后在启动类上添加@EnableBinding(RouterBindings.class)，并确保路由函数绑定到该输入通道，这样框架只会创建输入绑定，不会生成输出。

4. 检查自定义ConsumerMessageRoutingCallback的实现 #

确保你的回调逻辑中，返回的目标Bean都是纯Consumer类型，而非带有输出的Function。例如：

@Override
public String determineRoute(Message<?> message) {
    // 根据消息头获取目标Consumer Bean名称
    String targetConsumer = message.getHeaders().get("payload-type", String.class);
    // 确保返回的是已定义的Consumer Bean，而非Function
    return targetConsumer;
}

若回调中返回了Function类型的Bean名称，框架仍会触发输出绑定的创建，需严格控制路由目标为无输出的Consumer。

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