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 brokerIdList = new ArrayList<>(metadata.getBrokerIdSet().size()); + List brokerIdList = new ArrayList<>(metadata.getBrokerIdSet()); FutureTask[] taskList = new FutureTask[brokerIdList.size()]; for (int i = 0; i < brokerIdList.size(); ++i) {