From bb06e021a0367ab1f04454428dcf7e995a784b19 Mon Sep 17 00:00:00 2001
From: Andrey Pleskach <ples@aiven.io>
Date: Tue, 3 Oct 2023 20:26:21 +0200
Subject: [PATCH] Bump OpenSearch version to 2.10

Signed-off-by: Andrey Pleskach <ples@aiven.io>
---
 build.gradle                                                    | 2 +-
 .../java/io/aiven/kafka/connect/opensearch/BulkProcessor.java   | 2 +-
 .../io/aiven/kafka/connect/opensearch/BulkProcessorTest.java    | 2 +-
 .../io/aiven/kafka/connect/opensearch/RequestBuilderTest.java   | 2 +-
 4 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/build.gradle b/build.gradle
index b36987d0..146cc830 100644
--- 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
index 154e491d..483236f5 100644
--- 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
index 2b3ec1a7..b0d23b74 100644
--- 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
index ca706059..b2f78a3e 100644
--- 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;