[ISSUE apache#6627] Fix ConsumerLagCalculator#getAvailableMsgCount NP…

…E if group or topic is null
lizhimins · Apr 23, 2023 · df699ff · df699ff
1 parent af6a95f
commit df699ff
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/metrics/ConsumerLagCalculator.java b/broker/src/main/java/org/apache/rocketmq/broker/metrics/ConsumerLagCalculator.java
@@ -363,6 +363,10 @@ public Pair<Long, Long> getInFlightMsgStats(String group, String topic, int queu
     public long getAvailableMsgCount(String group, String topic, boolean isPop) {
         long total = 0L;
 
+        if (group == null || topic == null) {
+            return total;
+        }
+
         TopicConfig topicConfig = topicConfigManager.selectTopicConfig(topic);
         if (topicConfig != null) {
             for (int queueId = 0; queueId < topicConfig.getWriteQueueNums(); queueId++) {