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

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

jackson-module-scala apache-kafka jackson scala

novon · 技术社区 · 9 年前

我正在使用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 回复 | 直到 9 年前

ephemient 9 年前

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]])

推荐文章

queeg · Jackson使用t bean列表解析bean<t>

1 年前

Nuñito Calzada · 在Java中解析Json->INCLUDE_SOURCE_in_LOCATION `已禁用

1 年前

david7596 · Jackson将json解析为带有嵌套字段的Map<String,Object>,将嵌套字段正确解析为Map

2 年前

UndefinedUserAtSO · Quarkus无法将简单字符串序列化为JSON

2 年前

Joseph Gagnon · 将JSON数据转换为Java映射时出现问题

2 年前

Joseph Gagnon · 有没有办法将Java枚举序列化到YAML或从YAML序列化?

2 年前

Matías Santurio · Jackson:将同一个对象序列化为多个JSON

2 年前

CodeBot · JavaTuples API-无法反序列化,因为它们没有args构造函数

3 年前

Nicolas Sagala Beaucage · 带有路由器功能的Spring Boot 3 WebFlux无法从json反序列化Record

3 年前

ch1ll · 在mapper类中使用jackson的JsonView信息

3 年前