代码之家 › 专栏 › 技术社区 › novon

Kafka json反序列化器中泛型类型的Scala类

jackson-module-scala apache-kafka jackson scala

novon · 技术社区 · 7 年前

我正在使用Jackson在scala中编写kafka json反序列化程序,但在提供Jackson的 readValue() 方法泛型类型的类。例如:

...
import org.apache.kafka.common.serialization.Deserializer

class JsonDeserializer[T] extends Deserializer[Option[T]] {

  val mapper = (new ObjectMapper() with ScalaObjectMapper)
    .registerModule(DefaultScalaModule)
    .configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false)
    .registerModule(new JavaTimeModule())
    .findAndRegisterModules()
    .asInstanceOf[ObjectMapper with ScalaObjectMapper]

  def deserialize(topic: String, bytes: Array[Byte]): Option[T] = {
    Option(bytes) match {
      case Some(b) => Some(mapper.readValue(bytes, classOf[T]))
      case None => None
    }

  }

  def configure(configs: java.util.Map[String, _], isKey: Boolean) {}
  def close(): Unit = {}
}

mapper.readValue(bytes, classOf[T]) 在 deserialize

1 回复 | 直到 7 年前

ephemient 7 年前

Java中的泛型类型在运行时被擦除,因此无法恢复 Class

就Java而言,这是明确的。您可以使用 (implicit ct: ClassTag[T]) 或者速记 [T: ClassTag] ClassTag 在施工时,允许您检索 班

import scala.reflect._

class JsonDeserializer[T: ClassTag] extends Deserializer[Option[T]] {
  ...
    mapper.readValue(bytes, classTag[T].runtimeClass.asInstanceOf[Class[T]])

推荐文章

J E Carter II · 将ViewResolverRegistry添加到SpringWebConfig后,MappingJackson2JsonView Bean中断

6 年前

AdSR · 使用Jackson将JSON反序列化为异构元素列表

6 年前

Melad Basilius · 使用Jackson库更改派生类的JSON属性名称

6 年前

tgr · 将不匹配的数据模型从XML转换为JSON的最佳实践

6 年前

kzeray · Jackson JSON无限递归,不省略序列化中的任何内容

6 年前

Josh Maag · Spring Boot JSON空序列化

6 年前

Chad · Spring Boot使用Json作为请求参数,而不是实体/模型

6 年前

Tejashwini · 使用POJO字段名将POJO转换为JsonNode

6 年前

Maciej Treder · 如何遍历/迭代JsonNode以找到特定节点的父节点

6 年前

thomas77 · 配置JsonProcessingExceptionMapper以登录Dropwizard

6 年前