浏览代码

ISSUE-2962: skew calculation fixes

iliax 2 年之前
父节点
当前提交
6b0fac7631

+ 3 - 1
kafka-ui-api/src/main/java/com/provectus/kafka/ui/model/PartitionDistributionStats.java

@@ -38,8 +38,10 @@ public class PartitionDistributionStats {
     var partitionLeaders = new HashMap<Node, Integer>();
     var partitionsReplicated = new HashMap<Node, Integer>();
     var isr = new HashMap<Node, Integer>();
+    int partitionsCnt = 0;
     for (TopicDescription td : stats.getTopicDescriptions().values()) {
       for (TopicPartitionInfo tp : td.partitions()) {
+        partitionsCnt++;
         tp.replicas().forEach(r -> incr(partitionsReplicated, r));
         tp.isr().forEach(r -> incr(isr, r));
         if (tp.leader() != null) {
@@ -61,7 +63,7 @@ public class PartitionDistributionStats {
         isr,
         avgLeadersCntPerBroker,
         avgPartitionsPerBroker,
-        partitionReplications >= minPartitionsForSkewCalculation
+        partitionsCnt >= minPartitionsForSkewCalculation
     );
   }