第 26 節 Flink Kafka-Connector詳解

上篇：第 25 節 Flink 並行度詳解(Parallel)web 一、Kafka-connector Kafka中的partition機制和Flink的並行度機制深度結合 Kafka能夠做爲Flink的source和sink 任務失敗，經過設置kafka的offset來恢復應用 Kafka Consumer消費策略設置 二、Kafka Consumer的容錯 當checkpoint機制開啓的時

>>阅读原文<<