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