Spring Integration 6.2.0：Kafka OutboundChannelAdapter设sendFailureChannel仍抛异常

这属于预期行为，具体原因和逻辑如下：

1. sendFailureChannel的优先级与作用 #

Kafka Outbound Channel Adapter的sendFailureChannel是适配器级别的专属错误处理通道，专门捕获所有与Kafka发送流程相关的异常（包括序列化阶段、网络发送阶段的异常）。一旦配置该通道，框架会将所有此类异常包装为KafkaSendFailureException并直接路由到该通道，不会再将异常传播到消息头指定的errorChannel或全局错误通道。

2. 序列化异常的处理路径 #

Avro的SerializationException属于消息序列化阶段的异常，发生在KafkaTemplate实际发送消息之前。在Spring Integration的Kafka适配器逻辑中，这类前置异常会被捕获并包装进KafkaSendFailureException，最终同样路由到配置的sendFailureChannel，而非消息头中设置的CUSTOM_ERROR_CHANNEL。

3. CUSTOM_ERROR_CHANNEL未触发的原因 #

当为适配器显式配置sendFailureChannel后，该通道会成为所有Kafka发送相关异常的唯一处理入口，消息头中的ERROR_CHANNEL配置会被覆盖，因此CUSTOM_ERROR_CHANNEL对应的ServiceActivator永远不会被触发。

调整方案 #

如果需要让序列化异常走CUSTOM_ERROR_CHANNEL，可以参考以下两种方式：

• 方式一：移除sendFailureChannel配置
  去掉适配器的sendFailureChannel设置，此时异常会按照消息头中的ERROR_CHANNEL路由到CUSTOM_ERROR_CHANNEL。
• 方式二：在sendFailureChannel中区分异常类型并转发
  在KAFKA_SEND_FAILURE_CHANNEL的处理逻辑中，解析异常根因，将序列化异常手动转发到CUSTOM_ERROR_CHANNEL：

  @Autowired
  private ApplicationContext applicationContext;
  
  @ServiceActivator(inputChannel = KAFKA_SEND_FAILURE_CHANNEL)
  void logKafkaSendFailure(KafkaSendFailureException exception) {
      Throwable rootCause = ExceptionUtils.getRootCause(exception);
      if (rootCause instanceof SerializationException) {
          MessageChannel customErrorChannel = applicationContext.getBean(CUSTOM_ERROR_CHANNEL, MessageChannel.class);
          customErrorChannel.send(MessageBuilder.withPayload(rootCause).build());
      } else {
          log.error("Kafka发送失败:", exception);
      }
  }
  

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