Skip to content

Commit 3ee6a5b

Browse files
committed
Small optimization
1 parent 9d6e955 commit 3ee6a5b

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

api/src/main/java/io/kafbat/ui/service/TopicsService.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -344,14 +344,15 @@ private Map<TopicPartition, Optional<NewPartitionReassignment>> getPartitionsRea
344344
.map(Map.Entry::getKey)
345345
.toList();
346346

347+
Integer leader = topic.getPartitions().get(partition).getLeader();
348+
347349
// Iterate brokers and try to remove them from assignment
348350
// while partition replicas count != requested replication factor
349351
for (Integer broker : brokersUsageList) {
350352
if (brokers.size() == replicationFactorChange.getTotalReplicationFactor()) {
351353
break;
352354
}
353355
// Check is the broker the leader of partition
354-
Integer leader = topic.getPartitions().get(partition).getLeader();
355356
if (leader == null || !leader.equals(broker)) {
356357
brokers.remove(broker);
357358
brokersUsage.merge(broker, -1, Integer::sum);

0 commit comments

Comments
 (0)