diff --git a/core/src/test/scala/unit/kafka/integration/MetricsDuringTopicCreationDeletionTest.scala b/core/src/test/scala/unit/kafka/integration/MetricsDuringTopicCreationDeletionTest.scala
index 6555937d9fd..9e11980f607 100644
--- a/core/src/test/scala/unit/kafka/integration/MetricsDuringTopicCreationDeletionTest.scala
+++ b/core/src/test/scala/unit/kafka/integration/MetricsDuringTopicCreationDeletionTest.scala
@@ -145,8 +145,8 @@ class MetricsDuringTopicCreationDeletionTest extends KafkaServerTestHarness with
       // Delete topics
       for (t <- topics if running) {
           try {
-            adminZkClient.deleteTopic(t)
-            TestUtils.verifyTopicDeletion(zkClient, t, partitionNum, servers)
+            deleteTopic(t)
+            TestUtils.verifyTopicDeletion(null, t, partitionNum, servers)
           } catch {
           case e: Exception => e.printStackTrace()
           }