(第四彈)Flink——Flink 如何管理 Kafka 消費位點

     Flink與Spark Streaming不同的之處，就是在於Flink是純天然的支持Exactly-once模式，保證數據的不丟失。 概念介紹          檢查點（Checkpoint）是使 Apache Flink 能從故障恢復的一種內部機制。檢查點是 Flink 應用狀態的一個一致性副本，包括了輸入的讀取位點。在發生故障時，Flink 通過從檢查點加載應用程序狀態來恢復，並從

>>阅读原文<<