apache-flink - 用于 Elasticsearch 7x 的 Apache Flink 连接器

Question

我将 Flink 1.9.0 与 flink-connector-elasticsearch6_2.11 一起使用，但这无法连接到 ES 7x。

我查看了https://issues.apache.org/jira/browse/FLINK-13025并下载了快照 - flink-connector-elasticsearch7_2.12-1.10-SNAPSHOT.jar - 本地和flink-connector-elasticsearch-base_2。 11-1.9.1现在可以连接到 ES7。

这是否仍在开发中，因此尚未发布到 Maven 中心？关于发布日期的任何想法？

标签： apache-flinkflink-streamingelasticsearch-7

Answer 1

支持 ES7 的更新后的 Elasticsearch 连接器是最近发布的 Flink 1.10 的一部分。