浏览代码

Renames and optimizings

Roman Nedzvetskiy 5 年之前
父节点
当前提交
9b04938774

+ 0 - 1
kafka-ui-api/src/main/java/com/provectus/kafka/ui/cluster/model/InternalTopic.java

@@ -21,7 +21,6 @@ public class InternalTopic {
     private final int inSyncReplicas;
     private final int replicationFactor;
     private final int underReplicatedPartitions;
-    //TODO: find way to fill
     private final long segmentSize;
     private final int segmentCount;
     private final Map<TopicPartition, Long> partitionSegmentSize;

+ 1 - 1
kafka-ui-api/src/main/java/com/provectus/kafka/ui/cluster/util/JmxClusterUtil.java

@@ -97,7 +97,7 @@ public class JmxClusterUtil {
         }
     }
 
-    public List<MetricDto> squashIntoNameMetricPair(InternalClusterMetrics internalClusterMetrics) {
+    public List<MetricDto> convertToMetricDto(InternalClusterMetrics internalClusterMetrics) {
         return internalClusterMetrics.getInternalBrokerMetrics().values().stream()
                 .map(c ->
                         c.getJmxMetrics().stream()

+ 0 - 2
kafka-ui-api/src/main/java/com/provectus/kafka/ui/cluster/util/JmxMetricsNames.java

@@ -1,7 +1,5 @@
 package com.provectus.kafka.ui.cluster.util;
 
-import com.google.common.collect.ImmutableList;
-
 public enum JmxMetricsNames {
     MessagesInPerSec,
     BytesInPerSec,

+ 1 - 1
kafka-ui-api/src/main/java/com/provectus/kafka/ui/kafka/KafkaService.java

@@ -364,7 +364,7 @@ public class KafkaService {
 
     private InternalClusterMetrics calculateClusterMetrics(InternalClusterMetrics internalClusterMetrics) {
         return internalClusterMetrics.toBuilder().jmxMetrics(
-                    jmxClusterUtil.squashIntoNameMetricPair(internalClusterMetrics)
+                    jmxClusterUtil.convertToMetricDto(internalClusterMetrics)
                             .stream().map(c -> {
                         JmxMetric jmx = new JmxMetric();
                         jmx.setCanonicalName(c.getCanonicalName());