Fixed non leader removals

germanosin · germanosin · commit 9d6e955f1515 · 2025-06-06T11:08:42.000+02:00
diff --git a/api/src/main/java/io/kafbat/ui/service/TopicsService.java b/api/src/main/java/io/kafbat/ui/service/TopicsService.java
@@ -352,7 +352,7 @@ private Map<TopicPartition, Optional<NewPartitionReassignment>> getPartitionsRea
           }
           // Check is the broker the leader of partition
           Integer leader = topic.getPartitions().get(partition).getLeader();
-          if (leader != null && !leader.equals(broker)) {
+          if (leader == null || !leader.equals(broker)) {
             brokers.remove(broker);
             brokersUsage.merge(broker, -1, Integer::sum);
           }

Original file line number	Diff line number	Diff line change
`@@ -352,7 +352,7 @@ private Map<TopicPartition, Optional<NewPartitionReassignment>> getPartitionsRea`
`352`	`352`	`}`
`353`	`353`	`// Check is the broker the leader of partition`
`354`	`354`	`Integer leader = topic.getPartitions().get(partition).getLeader();`
`355`		`- if (leader != null && !leader.equals(broker)) {`
	`355`	`+ if (leader == null \|\| !leader.equals(broker)) {`
`356`	`356`	`brokers.remove(broker);`
`357`	`357`	`brokersUsage.merge(broker, -1, Integer::sum);`
`358`	`358`	`}`