Hi, mete. As Feng Jin said, I think you could make use of the metric ` currentEmitEventTimeLag`. Besides that, if you develop your job with the DataStream API, you could add a new operator to handle it by yourself.
Best, Hang Feng Jin <jinfeng1...@gmail.com> 于2024年5月17日周五 02:44写道： > Hi Mete > > You can refer to the metrics provided by the Kafka source connector. > > > https://nightlies.apache.org/flink/flink-docs-release-1.19/docs/connectors/datastream/kafka//#monitoring > > Best, > Feng > > On Thu, May 16, 2024 at 7:55 PM mete <efk...@gmail.com> 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 >> >> >>
