在 flink (scala) 中使用 kryo 在特定类型上注册 protobuf 序列化程序时出现问题

如何解决在 flink (scala) 中使用 kryo 在特定类型上注册 protobuf 序列化程序时出现问题

我有一个代码片段如下：

env.getConfig.registerTypeWithKryoSerializer(classOf[EventMeta],classOf[ProtobufSerializer[EventMeta]])

其中 EventMeta 是由 scalaPB 从 proto 消息生成的案例类。我们使用 flink 1.10.1 和 scala 2.11。

我试图翻译文档中的 Java 代码：env.getConfig.registerTypeWithKryoSerializer(EventMeta.class,ProtobufSerializer.class)，但编译器一直告诉我：

 overloaded method value registerTypeWithKryoSerializer with alternatives:
[error]   (x$1: Class[_],x$2: Class[_ <: com.esotericsoftware.kryo.Serializer[_]])Unit <and>
[error]   [T <: com.esotericsoftware.kryo.Serializer[_] with java.io.Serializable](x$1: Class[_],x$2: T)Unit
[error]  cannot be applied to (Class[com.here.lanes.laneroadreference.derivation.statefun.state.EventMeta.EventMeta],Class[org.apache.flink.statefun.flink.common.protobuf.ProtobufSerializer[com.here.lanes.laneroadreference.derivation.statefun.state.EventMeta.EventMeta]])
[error]     env.getConfig.registerTypeWithKryoSerializer(classOf[EventMeta],classOf[ProtobufSerializer[EventMeta]])

显然，ProtobufSerializer 在我们的 flink 版本中没有扩展 Serializer。 doc 或 ProtobufSerializer 中是否有错误？我该如何解决这个问题？