要将Flink与Elasticsearch集成,您需要在您的Maven项目中添加以下依赖项:

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-connector-elasticsearch7_2.12</artifactId>
    <version>1.13.0</version>
</dependency>

请注意,上述依赖是针对Flink 1.13.0版本和Elasticsearch 7.x版本的。如果您使用其他版本的Flink或Elasticsearch,请相应地调整依赖项的版本。

此外,您还需要添加Elasticsearch客户端的依赖项,以便在Flink中与Elasticsearch进行通信。您可以使用以下依赖项:

<dependency>
    <groupId>org.elasticsearch.client</groupId>
    <artifactId>elasticsearch-rest-high-level-client</artifactId>
    <version>7.13.2</version>
</dependency>

请注意,上述依赖是针对Elasticsearch 7.13.2版本的。如果您使用其他版本的Elasticsearch,请相应地调整依赖项的版本。

完成上述步骤后,您就可以在Flink中使用Elasticsearch作为sink来将数据写入Elasticsearch了。

flink sink Elasticsearch实现 maven依赖

原文地址: http://www.cveoy.top/t/topic/iIlS 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录