文章目錄

• Pre
• Question
• Answer
• 擴(kuò)展知識(shí)

---

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

我們看看消費(fèi)者反序列化，解析value的配置

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

Question

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

---

Answer

在實(shí)體類上增加如下注解

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

反序列化后，多了個(gè)節(jié)點(diǎn)

---

---

擴(kuò)展知識(shí)

Jackson JSON - Using @JsonTypeInfo annotation to handle polymorphic types

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。