apache-flink - 如何使用 flink-streaming 生成断电警报

Question

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

例如：我有一个通过 kafka 向 flink-job 发送数据的站点。

     假设我们在 1992 年 4 月 26 日 10:23:52 收到数据，因为该站点出现问题后没有发送任何数据。在这种情况下，我们想要生成一个警告说 POWER_OFF。

可以使用flink吗？

标签： apache-flinkflink-streamingflink-cep

Answer 1

这种心跳故障检测很容易用ProcessFunction. 文档中有一个示例。

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