Hi all,
we are planning to use flink as a connector between kafka and
external systems. We use protobuf as a message format in kafka. If
non-backward compatible changes occur we want to skip those messages
('protobuf.ignore-parse-errors' = 'true') but record an error and raise an
alert. I didn't find any way to record deserialization errors (
https://github.com/apache/flink/blob/3a15d1ce69ac21d619f60033ec45cae303489c8f/flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/deserialize/PbRowDataDeserializationSchema.java#L73),
does it exist?
