自定義 Data Source

準備工作 我們先來看下 Flink 從 Kafka topic 中獲取數據的 demo，首先你需要安裝好了 FLink 和 Kafka 。 運行啓動 Flink、Zookepeer、Kafka， 好了，都啓動了！ maven 依賴 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31

>>阅读原文<<