Regarding Kafka connect elastic sink connector

[Balasubramanian Natarajan <ba...@ilink-systems.com>]

Hello,

I got the following error when I create the elastic sink connector(13.0.0) for elastic search 8.1.2,

Caused by: org.apache.kafka.connect.errors.ConnectException: Bulk request failed
        at io.confluent.connect.elasticsearch.ElasticsearchClient$1.afterBulk(ElasticsearchClient.java:398)
        at org.elasticsearch.action.bulk.BulkRequestHandler$1.onFailure(BulkRequestHandler.java:64)
        at org.elasticsearch.action.ActionListener$Delegating.onFailure(ActionListener.java:66)
        at org.elasticsearch.action.ActionListener$RunAfterActionListener.onFailure(ActionListener.java:350)
        at org.elasticsearch.action.ActionListener$Delegating.onFailure(ActionListener.java:66)
        at org.elasticsearch.action.bulk.Retry$RetryHandler.onFailure(Retry.java:123)
        at io.confluent.connect.elasticsearch.ElasticsearchClient.lambda$null$1(ElasticsearchClient.java:175)
        ... 5 more
Caused by: org.apache.kafka.connect.errors.ConnectException: Failed to execute bulk request due to 'java.io.IOException: Unable to parse response body for Response{requestLine=POST /_bulk?timeout=1m HTTP/1.1, host=http://192.168.1.5:9200, response=HTTP/1.1 200 OK}' after 6 attempt(s)
        at io.confluent.connect.elasticsearch.RetryUtil.callWithRetries(RetryUtil.java:165)


  1.  Is elastic sink connector supports elastic search version 8. x?.
  2.  If it is not currently supported, when will I expect this support?.

Please help me to fix these issues.

Thanks,
Balasubramanian N.