MINOR: fix TopicCommand warning message.format.version output (#18311)

Reviewers: Ismael Juma <[email protected]>, Chia-Ping Tsai <[email protected]>
apache · Dec 25, 2024 · ab54901 · ab54901
1 parent 77712d5
commit ab54901
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
@@ -173,7 +173,7 @@ private static Properties parseTopicConfigsToBeAdded(TopicCommandOptions opts) {
             .forEach(pair -> props.setProperty(pair.get(0).trim(), pair.get(1).trim()));
         LogConfig.validate(props);
         if (props.containsKey(TopicConfig.MESSAGE_FORMAT_VERSION_CONFIG)) {
-            System.out.println("WARNING: The configuration ${TopicConfig.MESSAGE_FORMAT_VERSION_CONFIG}=${props.getProperty(TopicConfig.MESSAGE_FORMAT_VERSION_CONFIG)} is specified. " +
+            System.out.println("WARNING: The configuration " + TopicConfig.MESSAGE_FORMAT_VERSION_CONFIG + "=" + props.getProperty(TopicConfig.MESSAGE_FORMAT_VERSION_CONFIG) + " is specified. " +
                 "This configuration will be ignored if the version is newer than the inter.broker.protocol.version specified in the broker or " +
                 "if the inter.broker.protocol.version is 3.0 or newer. This configuration is deprecated and it will be removed in Apache Kafka 4.0.");
         }