修复获取TopN的Broker指标时，会出现部分指标缺失的问题(#657)

修复获取TopN的Broker指标时，会出现部分指标缺失的问题
2025-12-25 04:32:12 +08:00 · 2022-10-11 18:44:02 +08:00
parent 79f0a23813 780fdea2cc
commit a423a20480
1 changed files with 1 additions and 1 deletions
--- a/km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/BrokerMetricESDAO.java
+++ b/km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/BrokerMetricESDAO.java
@@ -92,7 +92,7 @@ public class BrokerMetricESDAO extends BaseMetricESDAO {
        Table<String, Long, List<MetricPointVO>> table = HashBasedTable.create();

        //2、查询指标
-        for(String metric : metricBrokerIds.keySet()){
+        for(String metric : metrics) {
            table.putAll(
                    this.listBrokerMetricsByBrokerIds(
                            clusterPhyId,