用于elasticsearch 7x的apache flink连接器

lfapxunr  于 2021-06-24  发布在  Flink
关注(0)|答案(2)|浏览(1114)

我使用的是flink 1.9.0和flink-connector-elasticsearch6\U 2.11,但它无法连接到es 7x。
我看着https://issues.apache.org/jira/browse/flink-13025 并在本地下载了snapshot-flink-connector-elasticsearch7_2.12-1.10-snapshot.jar,使用flink-connector-elasticsearch-base_2.11-1.9.1现在可以连接到es7。
这是否还在开发中,因此还没有发布到maven central?你知道发行日期吗?

kzipqqlq

kzipqqlq1#

flink-connector-elasticsearch7弹性接头
对于flink elasticsearch连接器,我使用了下面提到的以下依赖项和版本。
Flink:1.10.0
ElasticSearch:7.6.2
flink-connector-elasticsearch7弹性接头
斯卡拉:2.12.11
sbt:1.2.8
java:11.0.4版
请找出我在这里提供的详细答案。

kt06eoxx

kt06eoxx2#

支持es7的更新的elasticsearch连接器是最近发布的flink 1.10的一部分。

相关问题