chore: elastic-search client upgrade (#59)

* chore: elastic-search client upgrade

* ignore setMaxRetryTimeoutMillis config

* bump up dagger version

---------

Co-authored-by: rajuGT <raju.gt@gojek.com>

Author: rajuGT

dagger-core/build.gradle

@@ -29,7 +29,7 @@ def flinkVersion = rootProject.flinkVersion
 version = rootProject.file('version.txt').text.trim()
 
 def minimalVersion = version
-def dependenciesVersion = "0.5.1"
+def dependenciesVersion = "0.5.2"
 
 description = """dagger to the heart!"""
 
@@ -106,7 +106,7 @@ dependencies {
     dependenciesJar 'com.google.protobuf:protobuf-java:3.23.2'
     dependenciesJar 'com.google.protobuf:protobuf-java-util:3.1.0'
     dependenciesJar 'org.influxdb:influxdb-java:2.8'
-    dependenciesJar 'org.elasticsearch.client:elasticsearch-rest-client:6.6.1'
+    dependenciesJar 'org.elasticsearch.client:elasticsearch-rest-client:8.18.1'
     dependenciesJar 'com.google.cloud.bigtable:bigtable-hbase-2.x:2.10.0'
     dependenciesJar 'org.asynchttpclient:async-http-client:2.10.1'
     dependenciesJar 'io.vertx:vertx-pg-client:3.9.0'

dagger-core/src/main/java/com/gotocompany/dagger/core/processors/external/es/EsAsyncConnector.java

@@ -66,11 +66,16 @@ public EsAsyncConnector(EsSourceConfig esSourceConfig, ExternalMetricConfig exte
     protected void createClient() {
         if (esClient == null) {
             esClient = RestClient.builder(
-                    getHttpHosts()
-            ).setHttpClientConfigCallback(httpClientBuilder ->
-                    httpClientBuilder
-                            .setDefaultCredentialsProvider(getCredentialsProvider())
-                            .setDefaultRequestConfig(getRequestConfig())).setMaxRetryTimeoutMillis(esSourceConfig.getRetryTimeout()).build();
+                            getHttpHosts()
+                    ).setHttpClientConfigCallback(httpClientBuilder ->
+                            httpClientBuilder
+                                    .setDefaultCredentialsProvider(getCredentialsProvider())
+                                    .setDefaultRequestConfig(getRequestConfig()))
+                    .setRequestConfigCallback(requestConfigBuilder ->
+                            requestConfigBuilder
+                                    .setConnectTimeout(esSourceConfig.getConnectTimeout())
+                                    .setSocketTimeout(esSourceConfig.getSocketTimeout()))
+                    .build();
         }
     }
 

version.txt

@@ -1 +1 @@
-0.11.7
+0.11.8