Apache Flink 如何管理Kafka消費者offsets

問題導讀 1.Flink與kafka一起如何做Checkpointing ? 2.發生故障,Flink如何恢復的? 3.Kafka consumer offsets存儲在什麼位置? 下面一些詞簡單解釋: 1.檢查點對應Checkpointing 2.主題對應Topic 3.Job對應工作 ###################### 在我們這篇文章中,我們將逐步說明Apache Flink如何與A
相關文章
相關標籤/搜索