diff --git a/broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java b/broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java index e768c7f95eb4cd803c869a755bf44665d3c0a429..40d20863747bf83105c5b5e251c577a62647a7d3 100644 --- a/broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java +++ b/broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java @@ -134,8 +134,7 @@ public class BrokerStartup { MixAll.properties2Object(ServerUtil.commandLine2Properties(commandLine), brokerConfig); if (null == brokerConfig.getRocketmqHome()) { - System.out.printf("Please set the " + MixAll.ROCKETMQ_HOME_ENV - + " variable in your environment to match the location of the RocketMQ installation"); + System.out.printf("Please set the %s variable in your environment to match the location of the RocketMQ installation", MixAll.ROCKETMQ_HOME_ENV); System.exit(-2); } diff --git a/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java b/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java index 0a0c6562d6f70226d643ba24174536ec2b9765b5..d7a2b2b644d00cc56925be1c3b9cff15ce5c2dd5 100644 --- a/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java +++ b/namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java @@ -72,7 +72,7 @@ public class NamesrvStartup { namesrvConfig.setConfigStorePath(file); - System.out.printf("load config properties file OK, " + file + "%n"); + System.out.printf("load config properties file OK, %s%n", file); in.close(); } } @@ -123,7 +123,7 @@ public class NamesrvStartup { String tip = "The Name Server boot success. serializeType=" + RemotingCommand.getSerializeTypeConfigInThisServer(); log.info(tip); - System.out.printf(tip + "%n"); + System.out.printf("%s%n", tip); return controller; } catch (Throwable e) { diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/cluster/CLusterSendMsgRTCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/cluster/CLusterSendMsgRTCommand.java index 37d66e4c76c0d113b49b9485e6ffb6b39e576241..ecbe1f38a54def3368ec02e2f1893f516e29f73d 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/cluster/CLusterSendMsgRTCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/cluster/CLusterSendMsgRTCommand.java @@ -171,7 +171,7 @@ public class CLusterSendMsgRTCommand implements SubCommand { failCount ); } else { - System.out.printf(String.format("%s|%s|%s|%s|%s%n", getCurTime(), + System.out.printf("%s", String.format("%s|%s|%s|%s|%s%n", getCurTime(), machineRoom, clusterName, brokerName, new BigDecimal(rt).setScale(0, BigDecimal.ROUND_HALF_UP))); } diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerSubCommand.java index a6df8ea8ecf45a93c52c8067f74dddd10fe956b6..f3b1fccf32da190f86549bf31ff80263e3647aa1 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerSubCommand.java @@ -126,7 +126,7 @@ public class ConsumerSubCommand implements SubCommand { ConsumerRunningInfo consumerRunningInfo = defaultMQAdminExt.getConsumerRunningInfo(group, clientId, jstack); if (consumerRunningInfo != null) { - System.out.printf(consumerRunningInfo.formatString()); + System.out.printf("%s", consumerRunningInfo.formatString()); } } } catch (Exception e) { diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/message/PrintMessageSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/message/PrintMessageSubCommand.java index c8fced3b16e3d4baf99e579c12944d85b9597162..b204f0abfb09ec624afd2ed5646be72605b264b7 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/message/PrintMessageSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/message/PrintMessageSubCommand.java @@ -146,11 +146,11 @@ public class PrintMessageSubCommand implements SubCommand { printMessage(pullResult.getMsgFoundList(), charsetName, printBody); break; case NO_MATCHED_MSG: - System.out.printf(mq + " no matched msg. status=%s, offset=%s", pullResult.getPullStatus(), offset); + System.out.printf("%s no matched msg. status=%s, offset=%s", mq, pullResult.getPullStatus(), offset); break; case NO_NEW_MSG: case OFFSET_ILLEGAL: - System.out.printf(mq + " print msg finished. status=%s, offset=%s", pullResult.getPullStatus(), offset); + System.out.printf("%s print msg finished. status=%s, offset=%s", mq, pullResult.getPullStatus(), offset); break READQ; } } catch (Exception e) { diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateTopicSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateTopicSubCommand.java index 8fdb9d3dbf8f64a63996a2c7537a694a6a4eeb62..c9c8a88fd929e43fbd4462d8c2dc1362cb539957 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateTopicSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateTopicSubCommand.java @@ -138,7 +138,7 @@ 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(String.format("set broker orderConf. isOrder=%s, orderConf=[%s]", + System.out.printf("%s", String.format("set broker orderConf. isOrder=%s, orderConf=[%s]", isOrder, orderConf.toString())); } System.out.printf("create topic to %s success.%n", addr);