第 26 节 Flink Kafka-Connector详解

上篇：第 25 节 Flink 并行度详解(Parallel)web 一、Kafka-connector Kafka中的partition机制和Flink的并行度机制深度结合 Kafka能够做为Flink的source和sink 任务失败，经过设置kafka的offset来恢复应用 Kafka Consumer消费策略设置 二、Kafka Consumer的容错 当checkpoint机制开启的时

>>阅读原文<<