ccclyt/flink-training-exercises

This repository contains reference solutions and utility classes for the Flink Training exercises on http://training.data-artisans.com. 1.修改反序列化bug 2.升级es为5.4.0版本 3.添加kafka2es代码, 添加手动建mapping样例