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

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


The following commit(s) were added to refs/heads/trunk by this push:
     new 669d8610a25 KAFKA-18228 The MetricsDuringTopicCreationDeletionTest 
should delete topics to ensure that the metrics are recreated (#18163)
669d8610a25 is described below

commit 669d8610a25a87bacd924f45ec6230a26721916c
Author: Ken Huang <[email protected]>
AuthorDate: Sat Dec 14 01:35:08 2024 +0800

    KAFKA-18228 The MetricsDuringTopicCreationDeletionTest should delete topics 
to ensure that the metrics are recreated (#18163)
    
    Reviewers: TengYao Chi <[email protected]>, Chia-Ping Tsai 
<[email protected]>
---
 .../kafka/integration/MetricsDuringTopicCreationDeletionTest.scala    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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()
           }

Reply via email to