Issue #000 feat: Added ioThread count config for Restclient

search-api/search-core/src/main/java/org/sunbird/search/client/ElasticSearchUtil.java

@@ -9,7 +9,10 @@ import com.fasterxml.jackson.databind.ObjectMapper;
 import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.http.HttpHost;
+import org.apache.http.impl.nio.client.HttpAsyncClientBuilder;
+import org.apache.http.impl.nio.reactor.IOReactorConfig;
 import org.apache.http.util.EntityUtils;
+import org.elasticsearch.client.RestClientBuilder;
 import org.sunbird.search.util.SearchConstants;
 import org.sunbird.telemetry.logger.TelemetryManager;
 import org.elasticsearch.action.ActionListener;
@@ -102,8 +105,15 @@ public class ElasticSearchUtil {
 			for (String host : hostPort.keySet()) {
 				httpHosts.add(new HttpHost(host, hostPort.get(host)));
 			}
-			RestHighLevelClient client = new RestHighLevelClient(
-					RestClient.builder(httpHosts.toArray(new HttpHost[httpHosts.size()])));
+			RestClientBuilder builder = RestClient.builder(httpHosts.toArray(new HttpHost[httpHosts.size()]))
+					.setHttpClientConfigCallback(new RestClientBuilder.HttpClientConfigCallback() {
+						@Override
+						public HttpAsyncClientBuilder customizeHttpClient(HttpAsyncClientBuilder httpClientBuilder) {
+							return httpClientBuilder.setDefaultIOReactorConfig(
+									IOReactorConfig.custom().setIoThreadCount(8).build());
+						}
+					});
+			RestHighLevelClient client = new RestHighLevelClient(builder);
 			if (null != client)
 				esClient.put(indexName, client);
 		}

search-api/search-service/conf/application.conf

@@ -33,6 +33,51 @@ akka {
   # And then uncomment this line to debug the configuration.
   #
   #log-config-on-start = true
+  default-dispatcher {
+    # This will be used if you have set "executor = "fork-join-executor""
+    fork-join-executor {
+      # Min number of threads to cap factor-based parallelism number to
+      parallelism-min = 8
+
+      # The parallelism factor is used to determine thread pool size using the
+      # following formula: ceil(available processors * factor). Resulting size
+      # is then bounded by the parallelism-min and parallelism-max values.
+      parallelism-factor = 32.0
+
+      # Max number of threads to cap factor-based parallelism number to
+      parallelism-max = 64
+
+      # Setting to "FIFO" to use queue like peeking mode which "poll" or "LIFO" to use stack
+      # like peeking mode which "pop".
+      task-peeking-mode = "FIFO"
+    }
+  }
+  actors-dispatcher {
+    type = "Dispatcher"
+    executor = "fork-join-executor"
+    fork-join-executor {
+      parallelism-min = 8
+      parallelism-factor = 32.0
+      parallelism-max = 64
+    }
+    # Throughput for default Dispatcher, set to 1 for as fair as possible
+    throughput = 1
+  }
+  actor {
+    deployment {
+      /searchActor
+        {
+          router = smallest-mailbox-pool
+          nr-of-instances = 10
+          dispatcher = actors-dispatcher
+        }
+      /healthActor
+        {
+          nr-of-instances = 10
+          dispatcher = actors-dispatcher
+        }
+    }
+  }
 }
 
 ## Secret key