diff --git 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
index edc186f4..83145381 100644
--- 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,