MINOR: Improve error message for invalid topic in TopicCommand (#18714)

Reviewers: Divij Vaidya <[email protected]>
apache · Jan 30, 2025 · c0b5d33 · c0b5d33
1 parent 95abd17
commit c0b5d33
Showing 1 changed file with 1 addition and 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
@@ -210,7 +210,7 @@ private static void ensureTopicExists(List<String> foundTopics, Optional<String>
         // 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()));
         }
     }