From 9be7ec5b71246e8168ecad7361d6c8ab73b451bb Mon Sep 17 00:00:00 2001 From: yx9o Date: Mon, 27 Jan 2025 22:37:57 +0800 Subject: [PATCH] Only real topics are output in exceptions --- tools/src/main/java/org/apache/kafka/tools/TopicCommand.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tools/src/main/java/org/apache/kafka/tools/TopicCommand.java b/tools/src/main/java/org/apache/kafka/tools/TopicCommand.java index e5171057c6cc0..32272d4e92685 100644 --- a/tools/src/main/java/org/apache/kafka/tools/TopicCommand.java +++ b/tools/src/main/java/org/apache/kafka/tools/TopicCommand.java @@ -210,7 +210,7 @@ private static void ensureTopicExists(List foundTopics, Optional // If no topic name was mentioned, do not need to throw exception. if (requestedTopic.isPresent() && !requestedTopic.get().isEmpty() && requireTopicExists && foundTopics.isEmpty()) { // If given topic doesn't exist then throw exception - throw new IllegalArgumentException(String.format("Topic '%s' does not exist as expected", requestedTopic)); + throw new IllegalArgumentException(String.format("Topic '%s' does not exist as expected", requestedTopic.get())); } }