MINOR: Fix leak thread in DeleteTopicTest.testIncreasePartitionCountD…

…uringDeleteTopic (apache#14960) Reviewers: Lucas Brutschy <[email protected]>
lianetm · Dec 8, 2023 · 0ad059d · 0ad059d
1 parent 43c635f
commit 0ad059d
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/core/src/test/scala/unit/kafka/admin/DeleteTopicTest.scala b/core/src/test/scala/unit/kafka/admin/DeleteTopicTest.scala
@@ -223,11 +223,12 @@ class DeleteTopicTest extends QuorumTestHarness {
     // increase the partition count for topic
     val props = new Properties()
     props.setProperty(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, TestUtils.plaintextBootstrapServers(servers))
-    val adminClient = Admin.create(props)
-    try {
-      adminClient.createPartitions(Map(topic -> NewPartitions.increaseTo(2)).asJava).all().get()
-    } catch {
-      case _: ExecutionException =>
+    TestUtils.resource(Admin.create(props)) { adminClient =>
+      try {
+        adminClient.createPartitions(Map(topic -> NewPartitions.increaseTo(2)).asJava).all().get()
+      } catch {
+        case _: ExecutionException =>
+      }
     }
     // trigger a controller switch now
     val previousControllerId = controllerId
@@ -245,7 +246,6 @@ class DeleteTopicTest extends QuorumTestHarness {
     follower.startup()
     controller.startup()
     TestUtils.verifyTopicDeletion(zkClient, topic, 2, servers)
-    adminClient.close()
   }