使用@JsonTypeInfo进行JSON反序列化在Kafka消费者端失效问题

核心原因 #

你当前关闭了基于headers的类型传递，但Spring Kafka的JsonDeserializer默认不会自动从payload的@class字段推断类型——除非明确指定目标父类，让Jackson的多态类型机制生效。

解决方案 #

不需要自定义spring.json.value.type.method，只需调整以下配置即可：

1. 指定消费者目标类型为抽象父类
   在application.yml/application.properties中添加配置：

   spring.kafka.consumer.value-deserializer=org.springframework.kafka.support.serializer.JsonDeserializer
   spring.kafka.consumer.properties.spring.json.value.type=com.your.package.TaskDto
   spring.kafka.consumer.properties.spring.json.use.type.headers=false
   

   将com.your.package.TaskDto替换为你项目中TaskDto的实际全类名。

2. 验证生产者消息结构
   确保生产者发送的JSON payload中包含@class字段，示例结构如下：

   {
     "@class": "com.your.package.SimpleTaskDto",
     "taskId": "xxxx-xxxx-xxxx-xxxx",
     "data": {"key": "value"}
   }
   

   只要生产者使用JsonSerializer且实体类带有@JsonTypeInfo注解，Jackson会自动将@class字段写入payload，即便配置了spring.json.add.type.headers=false也不受影响。

3. 确保Jackson依赖与配置正确

   • 项目需引入jackson-databind依赖
   • 若使用UUID类型，需确保jackson-datatype-jdk8或jackson-datatype-uuid已引入，避免UUID反序列化异常

为什么不需要自定义type.method？ #

spring.json.value.type.method用于完全自定义类型解析逻辑（比如从特定业务字段、外部参数获取类型），而你的场景下，Jackson原生的@JsonTypeInfo多态识别机制已经能满足需求，只需让JsonDeserializer明确基于父类进行解析即可。

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