CODEWITHSUNDEEP
apache-flinkflink-streamingelasticsearch-7
ssen
ssen

Reputation: 105

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 https://issues.apache.org/jira/browse/FLINK-13025 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?

Upvotes: 1

Views: 1071

Answers (2)

Keshav Lodhi
Keshav Lodhi

Reputation: 3182

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.

Upvotes: 1

David Anderson
David Anderson

Reputation: 43717

An updated Elasticsearch connector that supports ES7 is part of Flink 1.10, which was recently released.

Upvotes: 2

Related Questions