咔呲咔呲噗噗

👍👍👍

记一次Flink消费kafka数据恢复机制

现在我有一个数据架构：Flink消费kafka，开启windows窗口聚合存ES。某天的晚上Flink挂机，未加报警机制，3小时后才发现。如何才能把丢失的Kafka数据补充回...

噗呲噗呲咔咔

666 1 2

咔呲咔呲噗噗

现在我有一个数据架构：Flink消费kafka，开启windows窗口聚合存ES。某天的晚上Flink挂机，未加报警机制，3小时后才发现。如何才能把丢失的Kafka数据补充回...

咔呲咔呲噗噗

👏👏👏👍✊🍻🍻🍻

Flink窗口统计海量数据至ElasticSearch

一、背景： 实现效果数据实时报表 二、历史解决方案： 1） 前端发生数据事件时，调用封装好的JS方法，抛出kafka消息，服务端使用Spark 微批消费Kafka...

噗呲噗呲咔咔

739 1 2

咔呲咔呲噗噗

一、背景： 实现效果数据实时报表 二、历史解决方案： 1） 前端发生数据事件时，调用封装好的JS方法，抛出kafka消息，服务端使用Spark 微批消费Kafka...