[ISSUE #8454] Active brokers number should be initailized to 1 in bro…

…ker heartbeat manager. (#8453) * active brokers should be 1 on computing if absent * active brokers number should be initailized to 1 in broker heartbeat manager.
apache · Jul 28, 2024 · cc484d5 · cc484d5
1 parent 3722431
commit cc484d5
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...ain/java/org/apache/rocketmq/controller/impl/heartbeat/DefaultBrokerHeartbeatManager.java b/...ain/java/org/apache/rocketmq/controller/impl/heartbeat/DefaultBrokerHeartbeatManager.java
@@ -184,7 +184,7 @@ public Map<String, Map<String, Integer>> getActiveBrokersNum() {
             .forEach(id -> {
                 map.computeIfAbsent(id.getClusterName(), k -> new HashMap<>());
                 map.get(id.getClusterName()).compute(id.getBrokerName(), (broker, num) ->
-                    num == null ? 0 : num + 1
+                    num == null ? 1 : num + 1
                 );
             });
         return map;

diff --git a/...c/main/java/org/apache/rocketmq/controller/impl/heartbeat/RaftBrokerHeartBeatManager.java b/...c/main/java/org/apache/rocketmq/controller/impl/heartbeat/RaftBrokerHeartBeatManager.java
@@ -263,7 +263,7 @@ public Map<String, Map<String, Integer>> getActiveBrokersNum() {
             .forEach(id -> {
                 map.computeIfAbsent(id.getClusterName(), k -> new HashMap<>());
                 map.get(id.getClusterName()).compute(id.getBrokerName(), (broker, num) ->
-                    num == null ? 0 : num + 1
+                    num == null ? 1 : num + 1
                 );
             });
         return map;