Spring Cloud Stream Kafka批量消费模式下两类异常处理方案咨询

你遇到的BadRequestEvent异常信息丢失问题，核心是Spring Cloud Stream Kafka Binder默认会在Kafka反序列化器工作完成后，额外执行一次消息转换逻辑：你配置的ErrorHandlingDeserializer已经正确返回了BadRequestEvent实例，但SCSt的转换层会把这个实例重新序列化再反序列化为你配置的默认类型RequestEvent，导致子类的FailedDeserializationInfo字段被完全丢弃。

1. 启用原生解码，禁用SCSt二次消息转换 #

直接让Binder透传Kafka反序列化器的原始返回结果，不需要SCSt二次处理，新增如下配置即可：

spring:
  cloud:
    stream:
      kafka:
        bindings:
          receive-in-0:
            consumer:
              # 开启原生解码，跳过Binder自带的消息转换逻辑
              use-native-decoding: true

这一步是核心配置，开启后你在消费函数中拿到的就是FailedRequestEventProvider返回的原始BadRequestEvent实例，以及正常反序列化的RequestEvent实例，不会出现字段丢失问题。

2. 补充JsonDeserializer配置（可选） #

为了避免正常消息的多态反序列化异常，可以补充配置JsonDeserializer的信任包，替换原来的默认类型配置：

spring:
  kafka:
    consumer:
      properties:
        spring.json.trusted.packages: "com.consumer.domain.event"

3. 消费侧区分处理两类消息 #

调整你的消费函数逻辑，按消息类型分别处理：

@Bean
public Consumer<List<RequestEvent>> receive() {
    return events -> {
        for (RequestEvent event : events) {
            if (event instanceof BadRequestEvent badEvent) {
                // 处理反序列化失败消息，直接投递DLQ无需重试
                handleDeserializationFailure(badEvent.getFailedDeserializationInfo());
                continue;
            }
            // 处理正常业务消息
            handleNormalEvent(event);
        }
    };
}

4. 简化方案：反序列化异常直接进DLQ无需进入业务逻辑 #

如果你不需要在业务侧处理反序列化失败的消息，完全可以不用实现failedDeserializationFunction，直接配置ErrorHandlingDeserializer抛出异常，同时配置SCSt的DLQ规则，让反序列化异常直接投递DLQ不重试，更符合你的需求：

spring:
  cloud:
    stream:
      kafka:
        bindings:
          receive-in-0:
            consumer:
              enable-dlq: true
              dlq-name: RequestEvent.DLQ
              # 配置反序列化异常直接进DLQ，不触发重试
              dlq-production-failed-exceptions: org.springframework.kafka.support.serializer.DeserializationException

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