From 30510781c6a3091db47cfe997dcdaab4713bf49d Mon Sep 17 00:00:00 2001 From: iliax Date: Mon, 10 Jul 2023 15:53:15 +0400 Subject: [PATCH] wip --- .../java/com/provectus/kafka/ui/mapper/ClusterMapper.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/kafka-ui-api/src/main/java/com/provectus/kafka/ui/mapper/ClusterMapper.java b/kafka-ui-api/src/main/java/com/provectus/kafka/ui/mapper/ClusterMapper.java index 0a93ab80d2..e4e15d7136 100644 --- a/kafka-ui-api/src/main/java/com/provectus/kafka/ui/mapper/ClusterMapper.java +++ b/kafka-ui-api/src/main/java/com/provectus/kafka/ui/mapper/ClusterMapper.java @@ -1,6 +1,8 @@ package com.provectus.kafka.ui.mapper; import static io.prometheus.client.Collector.MetricFamilySamples; +import static java.util.stream.Collectors.toList; +import static java.util.stream.Collectors.toMap; import com.provectus.kafka.ui.config.ClustersProperties; import com.provectus.kafka.ui.model.BrokerConfigDTO; @@ -31,6 +33,7 @@ import com.provectus.kafka.ui.model.TopicConfigDTO; import com.provectus.kafka.ui.model.TopicDTO; import com.provectus.kafka.ui.model.TopicDetailsDTO; import java.math.BigDecimal; +import java.util.LinkedHashMap; import java.util.List; import java.util.Map; import java.util.stream.Collectors; @@ -68,7 +71,8 @@ public interface ClusterMapper { .name(s.name) .labels(IntStream.range(0, s.labelNames.size()) .boxed() - .collect(Collectors.toMap(s.labelNames::get, s.labelValues::get))) + //collecting to map, keeping order + .collect(toMap(s.labelNames::get, s.labelValues::get, (m1, m2) -> null, LinkedHashMap::new))) .value(BigDecimal.valueOf(s.value)) ).toList(); } @@ -115,7 +119,7 @@ public interface ClusterMapper { List toFeaturesEnum(List features); default List map(Map map) { - return map.values().stream().map(this::toPartition).collect(Collectors.toList()); + return map.values().stream().map(this::toPartition).collect(toList()); } static KafkaAclDTO.OperationEnum mapAclOperation(AclOperation operation) {