容错

正如文档中所解释的那样,

启用 Flink 的检查点后,Flink Kafka Consumer 将使用主题中的记录,并以一致的方式定期检查其所有 Kafka 偏移以及其他操作的状态。如果作业失败,Flink 会将流式程序恢复到最新检查点的状态,并从存储在检查点中的偏移量开始重新使用来自 Kafka 的记录。

因此,绘制检查点的间隔定义了程序在发生故障时最多可以返回多少。

要使用容错 Kafka 使用者,你需要使用 enableCheckpointing 方法在执行环境中启用检查点:

final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.enableCheckpointing(5000); // checkpoint every 5 seconds