扫一扫加入大数据公众号和技术交流群，了解更多大数据技术，还有免费资料等你哦

简介

        Flink内置了Elasticsearch Connector用于对ES进行数据的操作，里面主要的类是ElasticsearchSink，使用时我们需要实现里面的抽象方法，自定义自己的逻辑。

版本说明：

ES版本：6.3.2    flink 1.6.1 

需要添加的依赖 

<dependency>
     <groupId>org.apache.flink</groupId>
     <artifactId>flink-connector-elasticsearch6_2.11</artifactId>
     <version>1.6.1</version>
</dependency>