From ab5490147537d9d4a581a6fde44dc43a27d6eb7c Mon Sep 17 00:00:00 2001 From: PoAn Yang Date: Wed, 25 Dec 2024 18:20:23 +0800 Subject: [PATCH] MINOR: fix TopicCommand warning message.format.version output (#18311) Reviewers: Ismael Juma , Chia-Ping Tsai --- 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 93b19adcf3c..464a8fcf00f 100644 --- 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 @@ public abstract class TopicCommand { .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."); }