Kafka消费者序列化失败：同类型不同包名对象问题

问题根源 #

默认情况下Spring Kafka的JSON序列化器会将事件类的全限定类名写入消息头__TypeId__中，消费者收到消息后会尝试加载这个全限定名对应的类，但你的消费者项目中只存在foo.bar.PostLikeEvent，找不到生产者那边的com.example.postlikeproducer.PostLikeEvent，因此抛出ClassNotFoundException；当关闭spring.json.use.type.headers=false后，消息头中不再携带类型信息，消费者无法确定要将消息反序列化成哪种类型，于是抛出IllegalStateException。

可行解决方案 #

方案1：给消费者指定默认反序列化类型

直接配置消费者的JSON反序列化器，指定默认的目标类型为本地的PostLikeEvent：

# 消费者核心配置
spring.kafka.consumer.value-deserializer=org.springframework.kafka.support.serializer.JsonDeserializer
spring.kafka.consumer.properties.spring.json.value.default.type=foo.bar.PostLikeEvent
# 若不需要类型头机制，可保留此配置；若需兼容多类型消息可移除
spring.kafka.consumer.properties.spring.json.use.type.headers=false

这种方式简单直接，适合仅消费单一类型消息的场景。

方案2：配置类型别名映射（推荐）

让生产者和消费者约定统一的类型别名，替代全限定类名写入消息头，规避包路径差异带来的类加载问题：

• 生产者端配置：

spring.kafka.producer.value-serializer=org.springframework.kafka.support.serializer.JsonSerializer
spring.kafka.producer.properties.spring.json.type.mapping=postLikeEvent:com.example.postlikeproducer.PostLikeEvent

• 消费者端配置：

spring.kafka.consumer.value-deserializer=org.springframework.kafka.support.serializer.JsonDeserializer
spring.kafka.consumer.properties.spring.json.type.mapping=postLikeEvent:foo.bar.PostLikeEvent

配置后，生产者发送消息时会用别名postLikeEvent代替全限定类名写入消息头，消费者拿到别名后会映射到本地的foo.bar.PostLikeEvent类，同时保留了类型头的多类型兼容能力，适合复杂消息场景。

注意事项

• 必须保证两个PostLikeEvent类的结构完全一致：字段名、字段类型、Getter/Setter方法都要精准匹配，否则会出现反序列化失败的情况。
• 若使用较低版本的Spring Boot，需注意检查JsonDeserializer与配置属性的兼容性，部分旧版本可能需要调整配置键名。

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