Bump OpenSearch version to 2.10

Signed-off-by: Andrey Pleskach <[email protected]>
Aiven-Open · Oct 3, 2023 · bb06e02 · bb06e02
1 parent fe465aa
commit bb06e02
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/build.gradle b/build.gradle
@@ -120,7 +120,7 @@ publishing {
 ext {
     kafkaVersion = "2.8.1"
     slf4jVersion = "1.7.36"
-    openSearchVersion = "2.9.0"
+    openSearchVersion = "2.10.0"
 
     testcontainersVersion = "1.19.0"
     confluentPlatformVersion = "4.1.4"

diff --git a/src/main/java/io/aiven/kafka/connect/opensearch/BulkProcessor.java b/src/main/java/io/aiven/kafka/connect/opensearch/BulkProcessor.java
@@ -46,7 +46,7 @@
 import org.opensearch.action.bulk.BulkResponse;
 import org.opensearch.client.RequestOptions;
 import org.opensearch.client.RestHighLevelClient;
-import org.opensearch.rest.RestStatus;
+import org.opensearch.core.rest.RestStatus;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

diff --git a/src/test/java/io/aiven/kafka/connect/opensearch/BulkProcessorTest.java b/src/test/java/io/aiven/kafka/connect/opensearch/BulkProcessorTest.java
@@ -39,8 +39,8 @@
 import org.opensearch.action.index.IndexRequest;
 import org.opensearch.client.RequestOptions;
 import org.opensearch.client.RestHighLevelClient;
-import org.opensearch.common.bytes.BytesReference;
 import org.opensearch.common.xcontent.XContentType;
+import org.opensearch.core.common.bytes.BytesReference;
 
 import io.aiven.kafka.connect.opensearch.BulkProcessor.BehaviorOnVersionConflict;
 

diff --git a/src/test/java/io/aiven/kafka/connect/opensearch/RequestBuilderTest.java b/src/test/java/io/aiven/kafka/connect/opensearch/RequestBuilderTest.java
@@ -32,7 +32,7 @@
 import org.opensearch.action.delete.DeleteRequest;
 import org.opensearch.action.index.IndexRequest;
 import org.opensearch.action.update.UpdateRequest;
-import org.opensearch.common.bytes.BytesReference;
+import org.opensearch.core.common.bytes.BytesReference;
 import org.opensearch.index.VersionType;
 
 import com.fasterxml.jackson.core.type.TypeReference;