From ad131f5a2c0d21f632c063fbcc064eb01e22dc08 Mon Sep 17 00:00:00 2001
From: xuguang <xuguang_i@didiglobal.com>
Date: Fri, 17 Dec 2021 14:41:04 +0800
Subject: [PATCH] =?UTF-8?q?bugfix:=20DidiHealthScoreStrategy.calTopicHealt?=
 =?UTF-8?q?hScore=E8=AE=A1=E7=AE=97topic=E5=81=A5=E5=BA=B7=E5=88=86?=
 =?UTF-8?q?=E6=97=B6=EF=BC=8C=E8=8E=B7=E5=8F=96topic=E7=9A=84brokerId?=
 =?UTF-8?q?=E5=BC=82=E5=B8=B8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/strategy/healthscore/DidiHealthScoreStrategy.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/strategy/healthscore/DidiHealthScoreStrategy.java b/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/strategy/healthscore/DidiHealthScoreStrategy.java
index fed4ccda..11adf30c 100644
--- a/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/strategy/healthscore/DidiHealthScoreStrategy.java
+++ b/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/strategy/healthscore/DidiHealthScoreStrategy.java
@@ -114,7 +114,7 @@ public class DidiHealthScoreStrategy extends AbstractHealthScoreStrategy {
             return Constant.INVALID_CODE;
         }
 
-        List<Integer> brokerIdList = new ArrayList<>(metadata.getBrokerIdSet().size());
+        List<Integer> brokerIdList = new ArrayList<>(metadata.getBrokerIdSet());
 
         FutureTask<Integer>[] taskList = new FutureTask[brokerIdList.size()];
         for (int i = 0; i < brokerIdList.size(); ++i) {