如何使用flink流生成断电警报

Question

如何使用flink流生成断电警报。

e.x：我有一个网站，它通过kafka向flink job发送数据。

比方说，我们在1992年4月26日10:23:52收到数据，在该网站出现问题后，它没有发送任何数据。在这种情况下，我们希望生成一个表示POWER_OFF的警报。

有可能使用燧石吗？

Answer 1

这种心跳故障检测可以用ProcessFunction轻松完成。文档中有一个示例。

您也可以使用CEP执行此操作：https://stackoverflow.com/a/60754081/2000823