flink 1.13和es7.8的依赖
时间: 2024-01-05 16:48:33 浏览: 100
Flink 1.13的依赖可以通过以下Maven坐标引入:
```
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-java_${scala.binary.version}</artifactId>
<version>1.13.0</version>
</dependency>
```
其中,`scala.binary.version`需要根据实际使用的Scala版本进行替换。
而与ES 7.8的集成需要使用Flink的`flink-connector-elasticsearch7`模块,可以通过以下Maven坐标引入:
```
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-connector-elasticsearch7_${scala.binary.version}</artifactId>
<version>1.13.0</version>
</dependency>
```
同时需要引入Elasticsearch的Java客户端,可以通过以下Maven坐标引入:
```
<dependency>
<groupId>org.elasticsearch.client</groupId>
<artifactId>elasticsearch-rest-client</artifactId>
<version>7.8.0</version>
</dependency>
```
阅读全文