How to generate power off alert using flink-streaming

Question

How to generate power off alert using flink-streaming.

e.x: I have a site which sends data to the flink-job via kafka.

     Let's say, we received data on 26 April 1992 10:23:52 after that site had some problem it did not send any data. In that case we want to generate an alert saying POWER_OFF.

Is it possible using flink?

Answer 1

This sort of heartbeat failure detection is easily accomplished with a ProcessFunction. There's an example in the documentation.

You could also do this with CEP: https://stackoverflow.com/a/60754081/2000823