Hi all, I am having problems with reading from protobuf kafka topics, this is error log

items_ (com.organization.proto.stream.production.customerOrder.v1.CustomerOrderEvent) at com.esotericsoftware.kryo.serializers.ObjectField.read(ObjectField.java:125) at com.esotericsoftware.kryo.serializers.FieldSerializer.read(FieldSerializer.java:528) at com.esotericsoftware.kryo.Kryo.readObject(Kryo.java:657) at org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer.copy(KryoSerializer.java:311) at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(CopyingChainingOutput.java:74) ... 22 more

Could anyone point to a guide on deserializing Protobuf with Flink?