You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gh...@apache.org on 2023/08/25 18:50:23 UTC
[kafka] branch 3.3 updated: KAFKA-15393: Improve shutdown behavior in MM2 integration tests (#14278)
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 <gr...@aiven.io>
AuthorDate: Thu Aug 24 12:24:34 2023 -0700
KAFKA-15393: Improve shutdown behavior in MM2 integration tests (#14278)
Reviewers: Yash Mayya <ya...@gmail.com>, Chris Egerton <ch...@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
*/