怎样实现超过一定时间没有收到消息就发出报警的功能？
有很多边缘机器人设备（我们称为 robot）往 Kafka 中发消息，如果超过一定时间没有收到消息我们就认为 robot 掉线了。
比如
robot1 2020-11-11 12:00:00 msginfo
之后 20 mins 一直没有收到 robot1 的消息，怎样才才能在 flink 中实现 2020-11-11 12:10:00 就发出报警呢？
flink 是消息驱动的，没有收到消息就不会触发操作，怎样在没有收到后续消息的条件下触发操作呢？
我试验了下 https://juejin.im/post/6844904193052901384 的例子，不满足我的应用场景。
这个例子相当于所用订单共用一个 timeService， 每一次遍历一下所有的订单。
我们必须 按 robotId 做 keyBy*来自志愿者整理的flink邮件归档
展开
收起
1
条回答
写回答
写回答
-
我理解这篇文章少介绍了 keyby 的逻辑。 可以keyby(robotId)，然后在 processFunction 里面使用 ValueState 存储最近一次 robot 的到达时间， 同时注册一个 20min 的timer来触发检测，在检测时候，取出 ValueState 的值都是同一个 robotId的。
*来自志愿者整理的flink邮件归档
2021-12-06 10:45:31赞同 展开评论 打赏
问答分类：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
