我正在使用带有flink-connector-elasticsearch6_2.11的Flink 1.9.0,但这无法连接到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 中心?对发布日期有任何想法吗?
支持 ES7 的更新 Elasticsearch 连接器是最近发布的 Flink 1.10 的一部分。
flink-connector-elasticsearch7
对于 Flink Elasticsearch 连接器,我使用了下面提到的以下依赖项和版本。
- 闪烁:1.10.0
- 弹性搜索:7.6.2
- Flink-Connector-elasticsearch7
- 斯卡拉:2.12.11
- SBT:1.2.8
- 爪哇:11.0.4
请在此处找到我提供的详细答案。