容錯

正如文件中所解釋的那樣，

啟用 Flink 的檢查點後，Flink Kafka Consumer 將使用主題中的記錄，並以一致的方式定期檢查其所有 Kafka 偏移以及其他操作的狀態。如果作業失敗，Flink 會將流式程式恢復到最新檢查點的狀態，並從儲存在檢查點中的偏移量開始重新使用來自 Kafka 的記錄。

因此，繪製檢查點的間隔定義了程式在發生故障時最多可以返回多少。

要使用容錯 Kafka 使用者，你需要使用 enableCheckpointing 方法在執行環境中啟用檢查點：

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