第 26 節 Flink Kafka-Connector詳解

上篇：第 25 節 Flink 並行度詳解(Parallel) 1、Kafka-connector Kafka中的partition機制和Flink的並行度機制深度結合 Kafka可以作爲Flink的source和sink 任務失敗，通過設置kafka的offset來恢復應用 Kafka Consumer消費策略設置 2、Kafka Consumer的容錯 當checkpoint機制開啓的時候，K

>>阅读原文<<