Spring Boot配置Kafka类型映射：Maven构建成功但运行报错

问题核心 #

1. 生产者发送消息时，仍将生产者端全类名com.producerservice.dto.UserDTO作为类型标识写入消息，导致消费者因找不到该类抛出ClassNotFoundException，即使调整了spring.json.type.mapping顺序也未生效。
2. 未配置ErrorHandlingDeserializer，无法处理序列化异常，触发IllegalStateException。

解决方案 #

1. 修正生产者配置 #

确保生产者使用别名作为消息的类型标识，而非全类名：

spring.kafka.producer.bootstrap-servers=localhost:9092
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.value-serializer=org.springframework.kafka.support.serializer.JsonSerializer
# 格式：别名:实际类名，指定类型标识字段（默认@class，可自定义）
spring.kafka.producer.properties.spring.json.type.mapping=UserDTO:com.producerservice.dto.UserDTO
spring.kafka.producer.properties.spring.json.type.id.field=@class

2. 完善消费者配置 #

配置ErrorHandlingDeserializer处理异常，并正确映射别名到本地类：

spring.kafka.consumer.bootstrap-servers=localhost:9092
spring.kafka.consumer.group-id=your-consumer-group-id
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
# 用ErrorHandlingDeserializer包裹JsonDeserializer，捕获序列化异常
spring.kafka.consumer.value-deserializer=org.springframework.kafka.support.serializer.ErrorHandlingDeserializer
# 指定实际的反序列化实现类
spring.kafka.consumer.properties.spring.deserializer.value.delegate.class=org.springframework.kafka.support.serializer.JsonDeserializer
# 对应生产者的别名，映射到消费者本地类
spring.kafka.consumer.properties.spring.json.type.mapping=UserDTO:com.consumerservice.dto.UserDTO
spring.kafka.consumer.properties.spring.json.trusted.packages=*
spring.kafka.consumer.properties.spring.json.type.id.field=@class

3. 必要操作 #

• 清理旧消息：之前发送的消息已携带错误的全类名标识，需清空对应Kafka主题或重新发送新消息。
• 验证别名一致性：生产者与消费者的spring.json.type.mapping中，别名必须完全一致，确保类型标识能正确映射。

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