flink + kafka + es 流式计算

首先讲一下背景，公司现在要做流式，最后敲定用flink来做（考虑flink在阿里的巨大成功）。我们的数据读取Kafka ，经过处理之后会存储到ES中。现在还处在研究阶段，把一些基本的东西跑通，写这篇博客希望做一个记录 也希望能给刚开始搞flinkd 朋友们一点帮助。 用到的技术：flink on yarn (1.7.0)    kafka(1.1.1)  es（1.7） maven(3.04) 

>>阅读原文<<