opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-01 05:46:12 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #5426] Fix mqadmin updateTopic CLI result print format problem (#5427)

Browse Source
This commit is contained in:
mxsm
2022-10-31 10:34:17 +08:00
committed by GitHub
parent dd4b666435
commit 520721d527
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateTopicSubCommand.java
+4 -4
View File
@@ -155,11 +155,11 @@ public class UpdateTopicSubCommand implements SubCommand {
String brokerName = CommandUtil.fetchBrokerNameByAddr(defaultMQAdminExt, addr);
String orderConf = brokerName + ":" + topicConfig.getWriteQueueNums();
defaultMQAdminExt.createOrUpdateOrderConf(topicConfig.getTopicName(), orderConf, false);
System.out.printf("%s", String.format("set broker orderConf. isOrder=%s, orderConf=[%s]",
System.out.printf("%s%n", String.format("set broker orderConf. isOrder=%s, orderConf=[%s]",
isOrder, orderConf.toString()));
}
System.out.printf("create topic to %s success.%n", addr);
System.out.printf("%s", topicConfig);
System.out.printf("%s%n", topicConfig);
return;
} else if (commandLine.hasOption('c')) {
@@ -186,10 +186,10 @@ public class UpdateTopicSubCommand implements SubCommand {
}
defaultMQAdminExt.createOrUpdateOrderConf(topicConfig.getTopicName(),
orderConf.toString(), true);
System.out.printf("set cluster orderConf. isOrder=%s, orderConf=[%s]", isOrder, orderConf);
System.out.printf("set cluster orderConf. isOrder=%s, orderConf=[%s]%n", isOrder, orderConf);
}
System.out.printf("%s", topicConfig);
System.out.printf("%s%n", topicConfig);
return;
}