Spring Cloud Stream 4.0.4 Producer errorChannelEnabled属性失效排查

核心问题1：异常抛出时机错误 #

你在Supplier中直接抛出的RuntimeException属于消息生成阶段的同步异常，此时消息还未进入Spring Cloud Stream的发送流程，因此不会触发error-channel-enabled配置的绑定错误通道。这类异常会直接被Spring Cloud Function的默认错误处理机制路由到全局errorChannel，而非你配置的atest1.g1.errors通道。

核心问题2：缺少RabbitMQ生产者确认/返回配置 #

日志中的警告明确提示“连接工厂未配置返回或确认机制”，这是因为Rabbit Binder的error-channel-enabled依赖于生产者确认（publisher confirms）和返回（publisher returns）机制——只有开启这两个配置，RabbitMQ才会将发送过程中的错误（如路由失败、队列不存在、权限拒绝等）回传给生产者，进而触发绑定的错误通道。

修正步骤 #

1. 配置RabbitMQ生产者确认与返回 #

更新application.properties，添加必要的生产者机制配置：

spring.cloud.function.definition=supplier_err
spring.cloud.stream.bindings.supplier_err-out-0.destination=atest1
spring.cloud.stream.bindings.supplier_err-out-0.group=g1
spring.cloud.stream.bindings.supplier_err-out-0.producer.error-channel-enabled=true

# 开启生产者确认与返回机制
spring.cloud.stream.rabbit.bindings.supplier_err-out-0.producer.publisher-confirm-type=correlated
spring.cloud.stream.rabbit.bindings.supplier_err-out-0.producer.publisher-returns=true
# 开启mandatory确保路由失败时返回错误
spring.cloud.stream.rabbit.bindings.supplier_err-out-0.producer.mandatory=true

2. 修正错误通道监听目标 #

对于Spring Cloud Stream 4.x的Rabbit生产者，绑定的错误通道名称格式为<bindingName>.errors（后者是消费者错误通道的格式）。因此你需要修改ServiceActivator的输入通道：

@ServiceActivator(inputChannel = "supplier_err-out-0.errors")
public void processError(ErrorMessage msg) {
    System.out.println("My test error: " + msg);
}

3. 模拟发送阶段的错误（验证配置） #

修改Supplier，让其返回正常消息，通过不存在的路由键/队列触发发送错误：

@Bean
public Supplier<Message<String>> supplier_err() {
    return () -> {
        System.out.println("Sending msg...");
        // 发送一条无法路由的消息（假设atest1交换机未绑定对应路由键的队列）
        return MessageBuilder.withPayload("test message")
                .setHeader(AmqpHeaders.ROUTING_KEY, "invalid-routing-key")
                .build();
    };
}

4. 捕获消息生成阶段的同步异常（可选） #

如果需要捕获Supplier执行时直接抛出的异常，需要监听全局errorChannel：

@ServiceActivator(inputChannel = "errorChannel")
public void handleGlobalError(ErrorMessage msg) {
    System.out.println("Global error caught: " + msg);
}

补充说明 #

• error-channel-enabled=true的作用是为每个生产者绑定创建专属错误通道，仅处理发送到RabbitMQ过程中产生的异步错误；
• 同步异常（如Supplier执行时直接抛出的异常）默认由全局errorChannel处理，若需自定义处理，可通过全局错误通道或配置Spring Cloud Function的错误处理回调；
• 若需要对生产者发送失败进行重试，可结合retry-template配置实现。

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