Apache Flink Connector for Elasticsearch 7X
I Was Using Flink 1.9.0 with Flink-Connector-Elasticsearch6_2.11, but This Cannot Connect to Es 7X. I Looked at and Downloaded the Snapshot...
I was using Flink 1.9.0 with flink-connector-elasticsearch6_2.11, but this cannot connect to ES 7x.
I looked at and downloaded the snapshot - flink-connector-elasticsearch7_2.12-1.10-SNAPSHOT.jar - locally and with flink-connector-elasticsearch-base_2.11-1.9.1 can now connect to ES7.
Is this still in dev and hence not released to maven central yet? Any idea regarding the release date?
2 Answers
An updated Elasticsearch connector that supports ES7 is part of Flink 1.10, which was recently released.
flink-connector-elasticsearch7
For Flink Elasticsearch Connector I have used the following dependencies and versions mentioned below.
- Flink: 1.10.0
- ElasticSearch: 7.6.2
- flink-connector-elasticsearch7
- Scala: 2.12.11
- SBT: 1.2.8
- Java: 11.0.4
Please find a detailed answer which I have provided here.
Sophia analyzes international trade, startup ecosystems, retail transformation, and supply chain logistics for modern digital publications.
