Skip to content

Commit

Permalink
clean up
Browse files Browse the repository at this point in the history
  • Loading branch information
dlg99 committed Sep 27, 2024
1 parent b9c5786 commit cd88109
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -754,17 +754,17 @@ 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) {
System.out.write(buffer, 0, size);
}
}
} else {
print(getTopics().getInternalStats(persistentTopic, metadata));
print(getTopics().getInternalStats(topic, metadata));
}
}
}
Expand Down

0 comments on commit cd88109

Please sign in to comment.