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.

2

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.

Your Answer

Sign up or log in

Sign up using Google Sign up using Facebook Sign up using Email and Password

Post as a guest

By clicking “Post Your Answer”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.