Add flink gauge to serialiser ?

[Frank Wilson]

Is there a way to add a gauge to a flink serializer? I’d like to calculate and expose the total time to process a given tuple including the serialisation/deserialisation time.

Or would it be a better idea to wrap the conctrete sink function (e.g. kafka producer) with an ‘instrumented sink’ adapter which has the gauge?

Thanks,

Frank