Hello mete. I found this SO article https://stackoverflow.com/questions/54293808/measuring-event-time-latency-with-flink-cep
If I'm not mistake, you can use Flink metrics system for operators and get time of processing event in operator. On 2024/05/16 11:54:44 mete wrote: > Hello, > > For an sql application using kafka as source (and kafka as sink) what would > be the recommended way to monitor for processing delay? For example, i want > to be able to alert if the app has a certain delay compared to some event > time field in the message. > > Best, > Mete >
