From 37d8ade40ea0f0c539e85f7d2a535d5365f87ce7 Mon Sep 17 00:00:00 2001 From: Andrew Ross Date: Wed, 29 Jan 2025 14:21:32 -0800 Subject: [PATCH] Replace usage of transitive shaded dependency Signed-off-by: Andrew Ross --- .../src/test/java/org/opensearch/plugin/kafka/KafkaUtils.java | 4 +--- 1 file changed, 1 insertion(+), 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 index 39af56ea04ed7..543a5ecfc5497 100644 --- 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 getAdminClient(String bootstrapServer, Function 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);