第 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

>>阅读原文<<