95-130-340-源碼-source-kafka相關-FlinkKafkaConsumer分析

1.世界 2.概述 2.1 FlinkKafkaConsumer Flink kafka consumer connector 是用來消費kafka數據到flink系統的連接器，作爲flink系統的一個source存在。目前flink支持的kafka版本有0.8、0.9、0.10、0.11以及2.0+。由於目前我們使用的kafka版本是0.10.0.1，所以接下來主要基於0.10來分析。 上圖是F

>>阅读原文<<