Spring Kafka无法解析类名求助：跨服务发送数据对象失败

问题场景 #

在两个Spring服务间通过Kafka传输数据对象时，出现类名解析失败，消费者无法匹配生产者发送的对象，报错信息：

Caused by: org.springframework.messaging.converter.MessageConversionException: failed to resolve class name. Caused by: java.lang.ClassNotFoundException

当前已配置的类映射：

• 生产者配置：spring.kafka.producer.properties.spring.json.type.mapping=event:com.ankit.orderservice.event.OrderPlacedEvent
• 消费者配置：spring.kafka.consumer.properties.spring.json.type.mapping: event:com.ankit.OrderPlacedEvent

问题原因 #

1. 生产者与消费者端的OrderPlacedEvent类全限定名不一致：生产者端类路径是com.ankit.orderservice.event.OrderPlacedEvent，消费者端是com.ankit.OrderPlacedEvent，路径不匹配导致反序列化时找不到对应类。
2. 消费者配置格式错误：如果使用properties文件，键值对需用=而非:，格式错误会导致映射规则不生效。

解决方案 #

1. 统一类全限定名
   将生产者和消费者端的OrderPlacedEvent类调整为相同的全限定名，比如统一为com.ankit.orderservice.event.OrderPlacedEvent；更规范的做法是将该类抽取为公共依赖模块，让两个服务都引入，确保类定义完全一致。

2. 修正配置格式
   消费者配置改用正确的键值对格式（properties文件用=），对应统一后的类名：

   spring.kafka.consumer.properties.spring.json.type.mapping=event:com.ankit.orderservice.event.OrderPlacedEvent
   

   如果是yaml配置，格式应为：

   spring:
     kafka:
       consumer:
         properties:
           spring.json.type.mapping: event:com.ankit.orderservice.event.OrderPlacedEvent
   

3. 验证消息头规则
   确认生产者发送的消息头中__TypeId__字段值为映射的别名event，消费者通过该别名匹配到对应类，确保序列化和反序列化规则完全对齐。

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