Scala classOfカフカjsonデシリアライザのジェネリックタイプ

Question

ジャクソンを使用して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 = {} 
} 

はdeserialize方法でmapper.readValue(bytes, classOf[T])に注目してください。コンパイルに失敗しましたが、 "クラスタイプが必要ですがTが見つかりました"。

どうすればいいですか？

Answer 1

Javaの汎用型は実行時に消去されるため、明示的に渡さずにClassを回復する方法はありません。

Javaについては明らかです。 (implicit ct: ClassTag[T])または略語[T: ClassTag]を使用して、建設時にClassTagを（暗黙的に）取得すると、後でClassを取得できます。

import scala.reflect._ 

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