Issue using https about kafka-connect-elasticsearch-source HOT 6 CLOSED

Ok, so it seems similar to this issue elastic/elasticsearch#28923
(If you look to the last answer)

I will put the fix using the correct prefix in version 1.2.

from kafka-connect-elasticsearch-source.

Hi @albertwgchu ,
I will try to reproduce the error locally with an integration test.

I've read about a similar issue here https://www.google.com/url?sa=t&source=web&rct=j&url=https://discuss.elastic.co/t/resolved-400-error-responseexception-when-using-example-request-code-for-java-rest-client/98445&ved=2ahUKEwiSlOzs9N_tAhVZPuwKHa3dBLgQFjAAegQIBxAC&usg=AOvVaw32nxEd1oo2s_PGGK2JXc6i
I will check in few days if the issue is similar.

from kafka-connect-elasticsearch-source.

@DarioBalinzo Thanks for responding so quickly. I'll take a look as well, I'm curious why https://github.com/inspectorioinc/kafka-connect-elasticsearch-source works with my instance of ES and not yours. I should also mention I am using ES 6.8.

Thanks again.

from kafka-connect-elasticsearch-source.

@DarioBalinzo weird, so if I change this it works:

--- a/src/main/java/com/github/dariobalinzo/elastic/ElasticRepository.java
+++ b/src/main/java/com/github/dariobalinzo/elastic/ElasticRepository.java
@@ -100,7 +100,7 @@ public final class ElasticRepository {
try {
resp = elasticConnection.getClient()
.getLowLevelClient()

•                .performRequest("GET", "_cat/indices");
  

•                .performRequest("GET", "/_cat/indices");
     } catch (IOException e) {
         logger.error("error in searching index names");
         throw new RuntimeException(e);
  

from kafka-connect-elasticsearch-source.

Hi @albertwgchu , thanks for sharing the details.
What kind of environment are you using? (local cluster, docker or aws?)

I don't understand your change in the ElasticRepository, it seems identical to me. Can you share the diff or maybe submit a simple PR?

I'm planning to look into this in the next days, but having more info and context will help me in solving this issue.
Thanks

from kafka-connect-elasticsearch-source.

Hi @DarioBalinzo,

It's the forward slash before cat.

.performRequest("GET", "_cat/indices"); // this doesn't work
.performRequest("GET", "/_cat/indices"); // this works

I'm using Docker cp all in one for Kafka and Elastic Cloud for Elastic Search.

Thanks.

from kafka-connect-elasticsearch-source.