现在我有一个数据架构：Flink消费kafka，开启windows窗口聚合存ES。某天的晚上Flink挂机，未加报警机制，3小时后才发现。如何才能把丢失的Kafka数据补充回...
发简信
IP属地：上海
-
记一次Flink消费kafka数据恢复机制
-
Flink窗口统计海量数据至ElasticSearch
一、背景： 实现效果数据实时报表 二、历史解决方案： 1） 前端发生数据事件时，调用封装好的JS方法，抛出kafka消息，服务端使用Spark 微批消费Kafka...