[kafka] branch 3.3 updated: KAFKA-15393: Improve shutdown behavior in MM2 integration tests (#14278)

[gharris]

This is an automated email from the ASF dual-hosted git repository.

gharris pushed a commit to branch 3.3
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/3.3 by this push:
     new a4098bfd168 KAFKA-15393: Improve shutdown behavior in MM2 integration 
tests (#14278)
a4098bfd168 is described below

commit a4098bfd1685fa009c683105ae8016a6ccc9d85f
Author: Greg Harris <greg.har...@aiven.io>
AuthorDate: Thu Aug 24 12:24:34 2023 -0700

    KAFKA-15393: Improve shutdown behavior in MM2 integration tests (#14278)
    
    Reviewers: Yash Mayya <yash.ma...@gmail.com>, Chris Egerton 
<chr...@aiven.io>
---
 .../integration/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 e3f7cc6016f..ef6770173ec 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
@@ -247,8 +247,6 @@ public class MirrorConnectorsIntegrationBaseTest {
             for (String x : backup.connectors()) {
                 backup.deleteConnector(x);
             }
-            deleteAllTopics(primary.kafka());
-            deleteAllTopics(backup.kafka());
         } finally {
             shuttingDown = true;
             try {
@@ -813,17 +811,6 @@ public class MirrorConnectorsIntegrationBaseTest {
         }
     }
 
-    /*
-     * delete all topics of the input kafka cluster
-     */
-    private static void deleteAllTopics(EmbeddedKafkaCluster cluster) throws 
Exception {
-        try (final Admin adminClient = cluster.createAdminClient()) {
-            Set<String> 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
      */