From d29f42e0a0b7358095e058125e7f97990527ff8e Mon Sep 17 00:00:00 2001 From: Timur Davletov Date: Thu, 29 Jul 2021 08:44:37 +0300 Subject: [PATCH] Fix for randomly failing tests (null in KafkaCluster.getTopics()) (#728) --- .../java/com/provectus/kafka/ui/service/ClustersStorage.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/kafka-ui-api/src/main/java/com/provectus/kafka/ui/service/ClustersStorage.java b/kafka-ui-api/src/main/java/com/provectus/kafka/ui/service/ClustersStorage.java index 2846bc4e78..048daacb76 100644 --- a/kafka-ui-api/src/main/java/com/provectus/kafka/ui/service/ClustersStorage.java +++ b/kafka-ui-api/src/main/java/com/provectus/kafka/ui/service/ClustersStorage.java @@ -5,6 +5,7 @@ import com.provectus.kafka.ui.mapper.ClusterMapper; import com.provectus.kafka.ui.model.Feature; import com.provectus.kafka.ui.model.KafkaCluster; import java.util.Collection; +import java.util.HashMap; import java.util.Map; import java.util.Optional; import java.util.concurrent.ConcurrentHashMap; @@ -34,6 +35,7 @@ public class ClustersStorage { kafkaClusters.put( clusterProperties.getName(), cluster.toBuilder() + .topics(new HashMap<>()) .features(Feature.getEnabledFeatures(cluster)) .build() );