8x48/KnowStreaming
1
0
Fork 0
mirror of https://github.com/didi/KnowStreaming.git synced 2026-01-03 11:28:12 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

bugfix: DidiHealthScoreStrategy.calTopicHealthScore计算topic健康分时，获取topic的brokerId异常

Browse Source
This commit is contained in:
xuguang
2021-12-17 14:41:04 +08:00
parent 39cccd568e
commit ad131f5a2c
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/strategy/healthscore/DidiHealthScoreStrategy.java
View File

@@ -114,7 +114,7 @@ public class DidiHealthScoreStrategy extends AbstractHealthScoreStrategy {
return Constant.INVALID_CODE; 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()]; FutureTask<Integer>[] taskList = new FutureTask[brokerIdList.size()];
for (int i = 0; i < brokerIdList.size(); ++i) { for (int i = 0; i < brokerIdList.size(); ++i) {