Flink如何管理Kafka consumer

在我們Flink Friday Tip的這一集中，我們將逐步說明Apache Flink如何與Apache Kafka協同工作，以確保Kafka主題的記錄以一次性保證進行處理。 檢查點是Apache Flink的內部機制，可以從故障中恢復。檢查點是Flink應用程序狀態的一致副本，包括輸入的讀取位置。如果發生故障，Flink將通過從檢查點加載應用程序狀態並從恢復的讀取位置繼續恢復應用程序，就像沒有

>>阅读原文<<