Close stats

Author: germanosin

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

@@ -2,15 +2,18 @@
 
 import io.kafbat.ui.model.InternalPartitionsOffsets;
 import io.kafbat.ui.model.KafkaCluster;
+import io.kafbat.ui.model.ServerStatusDTO;
 import io.kafbat.ui.model.Statistics;
 import java.util.List;
 import java.util.Map;
 import java.util.Objects;
 import java.util.concurrent.ConcurrentHashMap;
+import lombok.extern.slf4j.Slf4j;
 import org.apache.kafka.clients.admin.ConfigEntry;
 import org.apache.kafka.clients.admin.TopicDescription;
 import org.springframework.stereotype.Component;
 
+@Slf4j
 @Component
 public class StatisticsCache {
 
@@ -34,6 +37,13 @@ public synchronized void update(KafkaCluster c,
         c,
         stats.withClusterState(s -> s.updateTopics(descriptions, configs, partitionsOffsets))
     );
+    try {
+      if (!stats.getStatus().equals(ServerStatusDTO.INITIALIZING)) {
+        stats.close();
+      }
+    } catch (Exception e) {
+      log.error("Error closing cluster {} stats", c.getName(), e);
+    }
   }
 
   public synchronized void onTopicDelete(KafkaCluster c, String topic) {