From cd8810902ec6b7df10ced189295ec64a293647a8 Mon Sep 17 00:00:00 2001 From: Andrey Yegorov Date: Fri, 27 Sep 2024 14:39:02 -0700 Subject: [PATCH] clean up --- .../main/java/org/apache/pulsar/admin/cli/CmdTopics.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java index a5b151bc6d0a8..4cf60dd269b28 100644 --- a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java +++ b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java @@ -754,9 +754,9 @@ private class GetInternalStats extends CliCommand { @Override void run() throws PulsarAdminException, IOException { - String persistentTopic = validatePersistentTopic(topicName); + String topic = validateTopicName(topicName); if (streaming) { - try (InputStream in = getTopics().streamInternalStats(persistentTopic, metadata);) { + try (InputStream in = getTopics().streamInternalStats(topic, metadata);) { int size; byte[] buffer = new byte[2048]; while ((size = in.read(buffer)) != -1) { @@ -764,7 +764,7 @@ void run() throws PulsarAdminException, IOException { } } } else { - print(getTopics().getInternalStats(persistentTopic, metadata)); + print(getTopics().getInternalStats(topic, metadata)); } } }