Flink 讀取Kafka數據示例

1、目標 本例模擬中將集成Kafka與Flink：Flink實時從Kafka中獲取消息，每隔10秒去統計機器當前可用的內存數並將結果寫入到本地文件中或者打印出來。 2、環境 Apache Kafka 0.11.0.0 Apache Flink 1.3.2 Maven 3.5.3 本例運行在Windows環境本地，使用idea開發代碼，代碼進行的是本地測試，沒有跑在flink集羣上，參考博客中是跑在

>>阅读原文<<