flink + kafka + es 流式計算

首先講一下背景，公司現在要做流式，最後敲定用flink來做（考慮flink在阿里的巨大成功）。我們的數據讀取Kafka ，經過處理之後會存儲到ES中。現在還處在研究階段，把一些基本的東西跑通，寫這篇博客希望做一個記錄 也希望能給剛開始搞flinkd 朋友們一點幫助。 用到的技術：flink on yarn (1.7.0)    kafka(1.1.1)  es（1.7） maven(3.04) 

>>阅读原文<<