[SYNCOPE-1773] Changing ES conf properties to allow for multiple nodes

ext/elasticsearch/client-elasticsearch/src/main/java/org/apache/syncope/ext/elasticsearch/client/ElasticsearchClientContext.java

@@ -19,11 +19,12 @@
 package org.apache.syncope.ext.elasticsearch.client;
 
 import co.elastic.clients.elasticsearch.ElasticsearchClient;
-import java.util.List;
+import java.util.stream.Collectors;
 import org.apache.http.HttpHost;
 import org.apache.syncope.core.persistence.api.dao.AnyObjectDAO;
 import org.apache.syncope.core.persistence.api.dao.GroupDAO;
 import org.apache.syncope.core.persistence.api.dao.UserDAO;
+import org.identityconnectors.common.CollectionUtil;
 import org.springframework.boot.actuate.health.HealthContributor;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
 import org.springframework.boot.context.properties.EnableConfigurationProperties;
@@ -39,7 +40,8 @@ public class ElasticsearchClientContext {
     @Bean
     public ElasticsearchClientFactoryBean elasticsearchClientFactoryBean(final ElasticsearchProperties props) {
         return new ElasticsearchClientFactoryBean(
-                List.of(new HttpHost(props.getHostname(), props.getPort(), props.getScheme())));
+                CollectionUtil.nullAsEmpty(props.getHosts()).stream().
+                        map(HttpHost::create).collect(Collectors.toList()));
     }
 
     @ConditionalOnMissingBean

ext/elasticsearch/client-elasticsearch/src/main/java/org/apache/syncope/ext/elasticsearch/client/ElasticsearchProperties.java

@@ -18,46 +18,27 @@
  */
 package org.apache.syncope.ext.elasticsearch.client;
 
-import org.apache.http.HttpHost;
+import java.util.ArrayList;
+import java.util.List;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 
 @ConfigurationProperties("elasticsearch")
 public class ElasticsearchProperties {
 
-    private String hostname = "localhost";
-
-    private int port = 9200;
-
-    private String scheme = HttpHost.DEFAULT_SCHEME_NAME;
+    private List<String> hosts = new ArrayList<>();
 
     private int indexMaxResultWindow = 10000;
 
     private String numberOfShards = "1";
 
     private String numberOfReplicas = "1";
 
-    public String getHostname() {
-        return hostname;
-    }
-
-    public void setHostname(final String hostname) {
-        this.hostname = hostname;
-    }
-
-    public int getPort() {
-        return port;
-    }
-
-    public void setPort(final int port) {
-        this.port = port;
-    }
-
-    public String getScheme() {
-        return scheme;
+    public List<String> getHosts() {
+        return hosts;
     }
 
-    public void setScheme(final String scheme) {
-        this.scheme = scheme;
+    public void setHosts(final List<String> hosts) {
+        this.hosts = hosts;
     }
 
     public int getIndexMaxResultWindow() {

fit/core-reference/src/main/resources/core-elasticsearch.properties

@@ -15,9 +15,7 @@
 # specific language governing permissions and limitations
 # under the License.
 
-elasticsearch.hostname=localhost
-elasticsearch.port=9200
-elasticsearch.scheme=http
+elasticsearch.hosts[0]=http://localhost:9200
 elasticsearch.indexMaxResultWindow=10000
 elasticsearch.numberOfShards=1
 elasticsearch.numberOfReplicas=1

pom.xml

@@ -425,7 +425,7 @@ under the License.
 
     <disruptor.version>3.4.4</disruptor.version>
 
-    <elasticsearch.version>8.8.2</elasticsearch.version>
+    <elasticsearch.version>8.9.0</elasticsearch.version>
 
     <commons-jexl.version>3.3</commons-jexl.version>
     <commons-text.version>1.10.0</commons-text.version>

src/main/asciidoc/reference-guide/usage/customization.adoc

@@ -385,9 +385,7 @@ Create
 
 [source]
 ....
-elasticsearch.hostname=localhost
-elasticsearch.port=9200
-elasticsearch.scheme=http
+elasticsearch.hosts[0]=http://localhost:9200
 elasticsearch.indexMaxResultWindow=10000
 elasticsearch.numberOfShards=1
 elasticsearch.numberOfReplicas=1