From 1f2e12ca66736fc249ec99933b6f25f82942c819 Mon Sep 17 00:00:00 2001 From: Greg Harris Date: Tue, 22 Aug 2023 18:14:39 -0700 Subject: [PATCH] KAFKA-15393: Improve shutdown behavior in MM2 integration tests Signed-off-by: Greg Harris --- .../MirrorConnectorsIntegrationBaseTest.java | 13 ------------- 1 file changed, 13 deletions(-) diff --git a/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationBaseTest.java b/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationBaseTest.java index 4beeaaf876a74..6ea080a59a349 100644 --- a/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationBaseTest.java +++ b/connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationBaseTest.java @@ -262,8 +262,6 @@ public void shutdownClusters() throws Exception { for (String x : backup.connectors()) { backup.deleteConnector(x); } - deleteAllTopics(primary.kafka()); - deleteAllTopics(backup.kafka()); } finally { shuttingDown = true; try { @@ -1049,17 +1047,6 @@ protected static void waitForTopicCreated(EmbeddedConnectCluster cluster, String } } - /* - * delete all topics of the input kafka cluster - */ - private static void deleteAllTopics(EmbeddedKafkaCluster cluster) throws Exception { - try (final Admin adminClient = cluster.createAdminClient()) { - Set topicsToBeDeleted = adminClient.listTopics().names().get(); - log.debug("Deleting topics: {} ", topicsToBeDeleted); - adminClient.deleteTopics(topicsToBeDeleted).all().get(); - } - } - /* * retrieve the config value based on the input cluster, topic and config name */