Spring Kafka类型映射配置失败求助：消费者Maven构建报错

文档参考配置示例 #

spring.kafka.producer.properties.spring.json.type.mapping=cat:com.mycat.Cat,hat:com.myhat.Hat

生产者配置（Maven安装成功） #

spring.kafka.producer.bootstrap-server=localhost:9092
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.value-serializer=org.springframework.kafka.support.serializer.JsonSerializer 
spring.kafka.producer.properties.spring.json.type.mapping=com.producerservice.dto.UserDTO:UserDTO

消费者配置（Maven安装失败） #

spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.value-deserializer=org.springframework.kafka.support.serializer.JsonDeserializer
spring.kafka.consumer.properties.spring.json.type.mapping=com.consumerservice.dto.UserDTO:UserDTO
spring.kafka.consumer.properties.spring.json.trusted.packages=*

报错信息 #

Caused by: java.lang.IllegalArgumentException: Failed to load: UserDTO for com.consumerservice.dto.UserDTO
    at org.springframework.kafka.support.serializer.JsonSerializer.createMappings(JsonSerializer.java:188) ~[spring-kafka-2.8.8.jar:2.8.8]
    at org.springframework.kafka.support.serializer.JsonDeserializer.createMappings(JsonDeserializer.java:438) ~[spring-kafka-2.8.8.jar:2.8.8]
    at org.springframework.kafka.support.serializer.JsonDeserializer.configure(JsonDeserializer.java:418) ~[spring-kafka-2.8.8.jar:2.8.8]
    at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:716) ~[kafka-clients-3.1.1.jar:na]

问题分析与解决方案 #

核心问题 #

spring.json.type.mapping的配置格式完全写反了。参考文档里的格式是别名:全限定类名，但你在生产者和消费者端都写成了全限定类名:别名，导致反序列化时无法正确映射到目标类。

修正步骤 #

1. 调整生产者配置：
   将spring.kafka.producer.properties.spring.json.type.mapping修改为：

spring.kafka.producer.properties.spring.json.type.mapping=UserDTO:com.producerservice.dto.UserDTO

这样生产者会把UserDTO作为类型标识写入消息头。

2. 调整消费者配置：
   将spring.kafka.consumer.properties.spring.json.type.mapping修改为：

spring.kafka.consumer.properties.spring.json.type.mapping=UserDTO:com.consumerservice.dto.UserDTO

消费者收到带有UserDTO标识的消息时，会自动映射到本地项目的com.consumerservice.dto.UserDTO类完成反序列化。

验证逻辑 #

• 生产者发送com.producerservice.dto.UserDTO对象时，用UserDTO作为别名标记消息类型；
• 消费者识别消息头中的UserDTO别名，匹配到本地对应的实体类，完成反序列化流程。

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