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