Spring Cloud Stream 3.1.4版本生产者错误处理器不生效问题求助

1. 测试用例的异常不属于生产者错误通道处理范围

errorChannelEnabled 开启的错误通道，仅捕获 Spring Cloud Stream 消息发送到Broker过程中产生的异常，比如Broker不可达、消息序列化失败、分区计算错误这类由框架层面发送流程抛出的异常。你直接在produce方法里手动抛异常，此时还没调用streamBridge.send，异常是业务代码自行抛出的，不会进入Stream的错误处理链路。

2. 错误通道的命名配置错误

Spring Cloud Stream 3.1.x版本中，生产者绑定对应的错误通道命名规则为 <绑定名>.errors，你的生产绑定名是outputchannel-out-0，所以对应的错误通道名应为outputchannel-out-0.errors，你配置的errorchannel.errors是无效名称，自然接收不到错误消息。

1. 修正错误通道的监听名 #

修改@ServiceActivator的inputChannel参数为对应绑定的错误通道名：

@ServiceActivator(inputChannel = "outputchannel-out-0.errors")
public void errorHandler(ErrorMessage em) {
    log.info("Error: {}", em);
}

2. 正确的测试方式 #

模拟发送流程的错误即可触发错误处理器，可选测试场景：

• 关闭Kafka/RabbitMQ等消息中间件Broker，让消息发送失败
• 配置错误的序列化规则，触发消息序列化异常
• 故意传入非法的分区键，触发分区表达式计算错误
  示例测试代码：

public void produce(int messageId, Object message) {
    Message<Object> msg= MessageBuilder
            .withPayload(message)
            // 故意设置非法的partitionKey类型，触发分区表达式计算错误
            .setHeader("partitionKey", new Object())
            .build();
    streamBridge.send("outputchannel-out-0", msg);
}

3. 可选全局错误通道配置 #

如果需要监听所有生产者的错误，也可以直接监听全局错误通道：

@ServiceActivator(inputChannel = "errorChannel")
public void globalErrorHandler(ErrorMessage em) {
    log.info("Global error: {}", em);
}

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