Spring Kafka消费端报无法处理SerializationException错误如何修复

1. 异常出现在消费者拉取消息后的反序列化阶段，还未进入你编写的@KafkaListener业务逻辑，Spring Kafka默认的DefaultErrorHandler无法直接处理这类序列化异常。
2. 触发反序列化失败的常见场景包括：Topic中存在格式不兼容的历史脏消息、User类结构和生产者序列化时的结构不匹配、User类没有公共无参构造函数、字段类型不匹配等。

步骤1：替换消费者反序列化器为ErrorHandlingDeserializer #

修改消费者的application配置，用ErrorHandlingDeserializer包装实际的反序列化器，捕获反序列化阶段的异常，避免消费线程直接崩溃：

spring.kafka.consumer.bootstrap-servers=127.0.0.1:9092
# 替换原有反序列化配置为ErrorHandlingDeserializer
spring.kafka.consumer.key-deserializer=org.springframework.kafka.support.serializer.ErrorHandlingDeserializer
spring.kafka.consumer.value-deserializer=org.springframework.kafka.support.serializer.ErrorHandlingDeserializer
# 配置实际委托的反序列化器
spring.kafka.consumer.properties.spring.deserializer.key.delegate.class=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.properties.spring.deserializer.value.delegate.class=org.springframework.kafka.support.serializer.JsonDeserializer
# 原有配置保留
spring.kafka.consumer.properties.spring.json.trusted.packages=*
# 新增：指定反序列化目标类的全限定名，替换为你项目中User类的实际路径
spring.kafka.consumer.properties.spring.json.value.default.type=com.xxx.xxx.User
spring.kafka.consumer.group-id=user-group
server.port=8085

步骤2：检查反序列化目标类定义 #

确保你的User类存在公共的无参构造函数，Jackson反序列化Java对象必须依赖无参构造，否则会触发反序列化失败。

可选：清理脏消息（测试环境适用） #

如果是因为测试阶段往Topic中发送过格式不兼容的脏数据，可以直接删除user-topic后重启项目重建Topic，或者用Kafka命令行工具跳过报错偏移量的坏消息。 #

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