0ct0pu5/kafka-ui
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

sorting ACL list results to keep stable order on different calls

Browse source
This commit is contained in:
iliax 2023-05-12 12:53:04 +04:00
parent dd5d0cd421
commit 1c29bcb056
1 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
kafka-ui-api/src/main/java/com/provectus/kafka/ui/service/acl/AclsService.java
View file

@ -3,6 +3,7 @@ package com.provectus.kafka.ui.service.acl;
import com.google.common.collect.Sets; import com.google.common.collect.Sets;
import com.provectus.kafka.ui.model.KafkaCluster; import com.provectus.kafka.ui.model.KafkaCluster;
import com.provectus.kafka.ui.service.AdminClientService; import com.provectus.kafka.ui.service.AdminClientService;
import java.util.Comparator;
import java.util.List; import java.util.List;
import java.util.Set; import java.util.Set;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
@ -39,7 +40,8 @@ public class AclsService {
public Flux<AclBinding> listAcls(KafkaCluster cluster, ResourcePatternFilter filter) { public Flux<AclBinding> listAcls(KafkaCluster cluster, ResourcePatternFilter filter) {
return adminClientService.get(cluster) return adminClientService.get(cluster)
.flatMap(c -> c.listAcls(filter)) .flatMap(c -> c.listAcls(filter))
.flatMapIterable(acls -> acls); .flatMapIterable(acls -> acls)
.sort(Comparator.comparing(AclBinding::toString)); //sorting to keep stable order on different calls
} }
public Mono<String> getAclAsCsvString(KafkaCluster cluster) { public Mono<String> getAclAsCsvString(KafkaCluster cluster) {