Replace usage of transitive shaded dependency (#17194)

Signed-off-by: Andrew Ross <andrross@amazon.com>
opensearch-project · Jan 30, 2025 · 20a58eb · 20a58eb
1 parent d601c37
commit 20a58eb
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/plugins/ingestion-kafka/src/test/java/org/opensearch/plugin/kafka/KafkaUtils.java b/plugins/ingestion-kafka/src/test/java/org/opensearch/plugin/kafka/KafkaUtils.java
@@ -24,8 +24,6 @@
 import java.util.concurrent.TimeUnit;
 import java.util.function.Function;
 
-import org.testcontainers.shaded.com.google.common.collect.ImmutableMap;
-
 import static org.awaitility.Awaitility.await;
 
 public class KafkaUtils {
@@ -76,7 +74,7 @@ public static boolean checkTopicExistence(String topicName, String bootstrapServ
 
     private static <Rep> Rep getAdminClient(String bootstrapServer, Function<AdminClient, Rep> function) {
         AdminClient adminClient = KafkaAdminClient.create(
-            ImmutableMap.of(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServer, AdminClientConfig.CLIENT_ID_CONFIG, "test")
+            Map.of(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServer, AdminClientConfig.CLIENT_ID_CONFIG, "test")
         );
         try {
             return function.apply(adminClient);