(第四弹)Flink——Flink 如何管理 Kafka 消费位点

     Flink与Spark Streaming不同的之处，就是在于Flink是纯天然的支持Exactly-once模式，保证数据的不丢失。 概念介绍          检查点（Checkpoint）是使 Apache Flink 能从故障恢复的一种内部机制。检查点是 Flink 应用状态的一个一致性副本，包括了输入的读取位点。在发生故障时，Flink 通过从检查点加载应用程序状态来恢复，并从

>>阅读原文<<