Kafka反序列化嵌套的泛型类型答案

【问题标题】：Kafka Deserialize Nested Generic TypesKafka反序列化嵌套的泛型类型
【发布时间】：2018-08-14 05:26:47
【问题描述】：

给定这样的课程

public class Message<T> implements Serializable {
  final String correlationId;
  final LocalDateTime timestamp;
  final T payload
}

如何实现可以处理嵌套泛型类型的自定义 Kafka 反序列化器？

序列化应该非常简单，因为类型信息将可用。

但是如何处理反序列化时没有类型信息？

p.s：我是用jackson做序列化/反序列化的。

【问题讨论】：

标签： java jackson apache-kafka json-deserialization

【解决方案1】：

通过让 jackson 在序列化时包含类型信息来解决。

public class Message<T> implements Serializable {
  final String correlationId;
  final LocalDateTime timestamp;

  @JsonTypeInfo(use=JsonTypeInfo.Id.CLASS, include=JsonTypeInfo.As.PROPERTY, property="@class")
  final T payload
}

【讨论】：