Flink 1.17
Elasticsearch 8.1.1

Description:
Upgrading to Flink 1.17 from 1.8. ElasticsearchSink is already deprecated
and I am using the flink-connector-elasticsearch7.

This throws an IO exception, unable to parse response body. But when I
downgraded to Elasticsearch 7.17 it worked.

Question:
I couldn't find the elasticsearch connector for ES 8.x from the
documenation. How can I add a sink to ES 8.x version?

Thanks

Reply via email to