diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/stats/StatsAllSubCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/stats/StatsAllSubCommand.java index 802d9c7cfe165fe22f0d539bd92a17b5cfcd45f5..47070882e35bd21e6b6f2a4f9e42a04999483364 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/stats/StatsAllSubCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/stats/StatsAllSubCommand.java @@ -189,7 +189,7 @@ public class StatsAllSubCommand implements SubCommand { continue; } - if (selectTopic != null && selectTopic != "" && !topic.equals(selectTopic)) { + if (selectTopic != null && !selectTopic.isEmpty() && !topic.equals(selectTopic)) { continue; }