Does anybody experience the problem of metering deserialization errors?
пн, 17 июн. 2024 г. в 14:39, Ilya Karpov <idkf...@gmail.com>:
> 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?
>
