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 > > >
