文章目錄

• Pre
• Question
• Answer
• 擴展知識

---

Pre

#kafka spring.kafka.bootstrap-servers=10.11.114.247:9092 spring.kafka.producer.acks=1 spring.kafka.producer.retries=3 spring.kafka.producer.batch-size=16384 spring.kafka.producer.buffer-memory=33554432 spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer spring.kafka.producer.value-serializer=org.springframework.kafka.support.serializer.JsonSerializerspring.kafka.consumer.group-id=zfprocessor_group spring.kafka.consumer.enable-auto-commit=false spring.kafka.consumer.auto-offset-reset=earliest 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.trusted.packages=com.artisan.common.entity.messages spring.kafka.consumer.max-poll-records=500 spring.kafka.consumer.fetch-min-size=10 spring.kafka.consumer.fetch-max-wait=10000msspring.kafka.listener.missing-topics-fatal=false spring.kafka.listener.type=batch spring.kafka.listener.ack-mode=manuallogging.level.org.springframework.kafka=ERROR logging.level.org.apache.kafka=ERROR

我們看看消費者反序列化，解析value的配置

spring.kafka.consumer.value-deserializer=org.springframework.kafka.support.serializer.JsonDeserializer

Question

spring kafka 使用Jackson序列化， 如果存入kafka中的對象 包含 泛型，那么 默認情況下，這個泛型對象會被Jackson反序列為 LinkedHashMap . 拋出類型轉換異常…

---

Answer

在實體類上增加如下注解

@Data public class Message<T> {private int messageCode;@JsonTypeInfo(use = JsonTypeInfo.Id.CLASS,include = JsonTypeInfo.As.PROPERTY,property = "@class")private T messageContent;}

反序列化后，多了個節點

---

---

擴展知識

Jackson JSON - Using @JsonTypeInfo annotation to handle polymorphic types

總結

以上是生活随笔為你收集整理的Apache Kafka-Spring Kafka将泛型反序列化为对象而非LinkedHashMap的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。