chore(deps): bump elasticsearch-java from 8.12.0 to 9.3.0 (#713)

## AgentScope-Java Version

1.0.9

## Description

* chore(deps): bump elasticsearch-java from 8.12.0 to 9.3.0
* Closes: #710 

## Checklist

Please check the following items before code is ready to be reviewed.

- [x]  Code has been formatted with `mvn spotless:apply`
- [x]  All tests are passing (`mvn test`)
- [x]  Javadoc comments are complete and follow project conventions
- [x] Related documentation has been updated (e.g. links, examples,
etc.)
- [x]  Code is ready for review

Author: guanxuc

agentscope-dependencies-bom/pom.xml

@@ -83,7 +83,8 @@
         <slf4j.version>2.0.17</slf4j.version>
         <qdrant.version>1.16.2</qdrant.version>
         <milvus.version>2.6.13</milvus.version>
-        <elasticsearch.version>8.12.0</elasticsearch.version>
+        <httpclient5.version>5.6</httpclient5.version>
+        <elasticsearch.version>9.3.0</elasticsearch.version>
         <postgresql.version>42.7.9</postgresql.version>
         <pgvector.version>0.1.6</pgvector.version>
         <pdfbox.version>3.0.6</pdfbox.version>
@@ -111,7 +112,6 @@
         <kotlin.coroutines.version>1.10.2</kotlin.coroutines.version>
         <jgit.version>7.5.0.202512021534-r</jgit.version>
 
-
         <spotless.version>3.2.1</spotless.version>
         <maven-gpg-plugin.version>3.2.8</maven-gpg-plugin.version>
         <maven-deploy-plugin.version>3.1.4</maven-deploy-plugin.version>
@@ -240,6 +240,13 @@
                 <version>${qdrant.version}</version>
             </dependency>
 
+            <!-- Apache HTTP Client 5 -->
+            <dependency>
+                <groupId>org.apache.httpcomponents.client5</groupId>
+                <artifactId>httpclient5</artifactId>
+                <version>${httpclient5.version}</version>
+            </dependency>
+
             <!-- Elasticsearch Java SDK -->
             <dependency>
                 <groupId>co.elastic.clients</groupId>

agentscope-examples/advanced/pom.xml

@@ -44,7 +44,7 @@
             <dependency>
                 <groupId>co.elastic.clients</groupId>
                 <artifactId>elasticsearch-java</artifactId>
-                <version>8.12.0</version>
+                <version>9.3.0</version>
             </dependency>
 
             <!-- Spring Boot BOM -->

agentscope-extensions/agentscope-extensions-rag-simple/pom.xml

@@ -76,6 +76,12 @@
             <artifactId>milvus-sdk-java</artifactId>
         </dependency>
 
+        <!-- Apache HTTP Client 5 -->
+        <dependency>
+            <groupId>org.apache.httpcomponents.client5</groupId>
+            <artifactId>httpclient5</artifactId>
+        </dependency>
+
         <!-- Elasticsearch Java SDK -->
         <dependency>
             <groupId>co.elastic.clients</groupId>

agentscope-extensions/agentscope-extensions-rag-simple/src/main/java/io/agentscope/core/rag/store/ElasticsearchStore.java

@@ -17,6 +17,7 @@
 
 import co.elastic.clients.elasticsearch.ElasticsearchClient;
 import co.elastic.clients.elasticsearch._types.mapping.DenseVectorProperty;
+import co.elastic.clients.elasticsearch._types.mapping.DenseVectorSimilarity;
 import co.elastic.clients.elasticsearch._types.mapping.KeywordProperty;
 import co.elastic.clients.elasticsearch._types.mapping.Property;
 import co.elastic.clients.elasticsearch._types.mapping.TextProperty;
@@ -31,7 +32,8 @@
 import co.elastic.clients.elasticsearch.indices.ExistsRequest;
 import co.elastic.clients.json.jackson.JacksonJsonpMapper;
 import co.elastic.clients.transport.ElasticsearchTransport;
-import co.elastic.clients.transport.rest_client.RestClientTransport;
+import co.elastic.clients.transport.rest5_client.Rest5ClientTransport;
+import co.elastic.clients.transport.rest5_client.low_level.Rest5Client;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import io.agentscope.core.message.ContentBlock;
 import io.agentscope.core.message.TextBlock;
@@ -44,13 +46,13 @@
 import java.util.List;
 import java.util.Map;
 import javax.net.ssl.SSLContext;
-import org.apache.http.HttpHost;
-import org.apache.http.auth.AuthScope;
-import org.apache.http.auth.UsernamePasswordCredentials;
-import org.apache.http.conn.ssl.NoopHostnameVerifier;
-import org.apache.http.impl.client.BasicCredentialsProvider;
-import org.apache.http.ssl.SSLContextBuilder;
-import org.elasticsearch.client.RestClient;
+import org.apache.hc.client5.http.auth.AuthScope;
+import org.apache.hc.client5.http.auth.UsernamePasswordCredentials;
+import org.apache.hc.client5.http.impl.auth.BasicCredentialsProvider;
+import org.apache.hc.client5.http.ssl.DefaultClientTlsStrategy;
+import org.apache.hc.client5.http.ssl.NoopHostnameVerifier;
+import org.apache.hc.core5.http.HttpHost;
+import org.apache.hc.core5.ssl.SSLContextBuilder;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import reactor.core.publisher.Mono;
@@ -94,7 +96,7 @@ public class ElasticsearchStore implements VDBStoreBase, AutoCloseable {
 
     private final String indexName;
     private final int dimensions;
-    private final RestClient restClient;
+    private final Rest5Client restClient;
     private final ElasticsearchTransport transport;
     private final ElasticsearchClient client;
     private final boolean disableSslVerification;
@@ -110,8 +112,9 @@ private ElasticsearchStore(Builder builder) throws VectorStoreException {
             BasicCredentialsProvider credsProv = new BasicCredentialsProvider();
             if (builder.username != null && builder.password != null) {
                 credsProv.setCredentials(
-                        AuthScope.ANY,
-                        new UsernamePasswordCredentials(builder.username, builder.password));
+                        new AuthScope(null, -1),
+                        new UsernamePasswordCredentials(
+                                builder.username, builder.password.toCharArray()));
             }
 
             final SSLContext sslContext;
@@ -127,29 +130,30 @@ private ElasticsearchStore(Builder builder) throws VectorStoreException {
             HttpHost host = HttpHost.create(builder.url);
 
             this.restClient =
-                    RestClient.builder(host)
+                    Rest5Client.builder(host)
                             .setHttpClientConfigCallback(
                                     httpClientBuilder -> {
                                         if (builder.username != null) {
                                             httpClientBuilder.setDefaultCredentialsProvider(
                                                     credsProv);
                                         }
-
+                                    })
+                            .setConnectionManagerCallback(
+                                    connectionManager -> {
                                         if (builder.url != null
-                                                && builder.url.startsWith("https")) {
-                                            httpClientBuilder.setSSLContext(sslContext);
-                                            if (builder.disableSslVerification) {
-                                                httpClientBuilder.setSSLHostnameVerifier(
-                                                        NoopHostnameVerifier.INSTANCE);
-                                            }
+                                                && builder.url.startsWith("https")
+                                                && builder.disableSslVerification) {
+                                            connectionManager.setTlsStrategy(
+                                                    new DefaultClientTlsStrategy(
+                                                            sslContext,
+                                                            NoopHostnameVerifier.INSTANCE));
                                         }
-                                        return httpClientBuilder;
                                     })
                             .build();
 
             // 2. Create Transport and Client
             this.transport =
-                    new RestClientTransport(restClient, new JacksonJsonpMapper(OBJECT_MAPPER));
+                    new Rest5ClientTransport(restClient, new JacksonJsonpMapper(OBJECT_MAPPER));
             this.client = new ElasticsearchClient(transport);
 
             // 3. Ensure Index Exists
@@ -348,7 +352,7 @@ private void ensureIndex() throws VectorStoreException {
                                     new DenseVectorProperty.Builder()
                                             .dims(dimensions)
                                             .index(true)
-                                            .similarity("cosine")
+                                            .similarity(DenseVectorSimilarity.Cosine)
                                             .build())
                             .build();
 

agentscope-extensions/agentscope-extensions-rag-simple/src/test/java/io/agentscope/core/rag/store/ElasticsearchStoreTest.java

@@ -28,6 +28,7 @@
 
 import co.elastic.clients.elasticsearch.ElasticsearchClient;
 import co.elastic.clients.elasticsearch._types.Result;
+import co.elastic.clients.elasticsearch._types.mapping.DenseVectorSimilarity;
 import co.elastic.clients.elasticsearch._types.mapping.Property;
 import co.elastic.clients.elasticsearch.core.BulkRequest;
 import co.elastic.clients.elasticsearch.core.BulkResponse;
@@ -277,7 +278,7 @@ void testEnsureIndexCreatesIndex() throws VectorStoreException, IOException {
             Property vectorProp = props.get("vector");
             assertTrue(vectorProp.isDenseVector());
             assertEquals(TEST_DIMENSIONS, vectorProp.denseVector().dims());
-            assertEquals("cosine", vectorProp.denseVector().similarity());
+            assertEquals(DenseVectorSimilarity.Cosine, vectorProp.denseVector().similarity());
             assertTrue(vectorProp.denseVector().index());
 
             // Verify Content field