I am seeing this warning msg when trying to use a custom protobuf de/serializer with kafka source with auto generated java protobuf class:
18:41:31.164 [main] INFO org.apache.flink.api.java.typeutils.TypeExtractor - Class class com.xx.APITrace cannot be used as a POJO type because not all fields are valid POJO fields, and must be processed as GenericType. Please read the Flink documentation on "Data Types & Serialization" for details of the effect on performance. here is my serializer. What am i doing wrong? class ApiTraceSchema: DeserializationSchema<Trace.APITrace>, SerializationSchema<Trace.APITrace> { override fun getProducedType(): TypeInformation<Trace.APITrace> { return TypeInformation.of(Trace.APITrace::class.java) } override fun deserialize(message: ByteArray): Trace.APITrace { return Trace.APITrace.parseFrom(message) } override fun isEndOfStream(nextElement: Trace.APITrace): Boolean { return false } override fun serialize(element: Trace.APITrace): ByteArray { return element.toByteArray() } }