Apache Flink 如何管理Kafka消费者offsets

问题导读 1.Flink与kafka一起如何做Checkpointing ? 2.发生故障,Flink如何恢复的? 3.Kafka consumer offsets存储在什么位置? 下面一些词简单解释: 1.检查点对应Checkpointing 2.主题对应Topic 3.Job对应工作 ###################### 在我们这篇文章中,我们将逐步说明Apache Flink如何与A
相关文章
相关标签/搜索