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.
