diff --git a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/metrics/BaseMetrics.java b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/metrics/BaseMetrics.java index 2ab9af97..c6ce6351 100644 --- a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/metrics/BaseMetrics.java +++ b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/entity/metrics/BaseMetrics.java @@ -36,7 +36,7 @@ public abstract class BaseMetrics implements Serializable { return metrics.get(key); } - public BaseMetrics(Long clusterPhyId){ + protected BaseMetrics(Long clusterPhyId) { this.clusterPhyId = clusterPhyId; } diff --git a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/event/metric/BrokerMetricEvent.java b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/event/metric/BrokerMetricEvent.java index 150e7b7a..afba5938 100644 --- a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/event/metric/BrokerMetricEvent.java +++ b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/event/metric/BrokerMetricEvent.java @@ -11,7 +11,7 @@ import java.util.List; @Getter public class BrokerMetricEvent extends BaseMetricEvent{ - private List brokerMetrics; + private final List brokerMetrics; public BrokerMetricEvent(Object source, List brokerMetrics) { super( source ); diff --git a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/event/metric/ClusterMetricEvent.java b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/event/metric/ClusterMetricEvent.java index e4a16c99..aaf38896 100644 --- a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/event/metric/ClusterMetricEvent.java +++ b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/event/metric/ClusterMetricEvent.java @@ -11,7 +11,7 @@ import java.util.List; @Getter public class ClusterMetricEvent extends BaseMetricEvent{ - private List clusterMetrics; + private final List clusterMetrics; public ClusterMetricEvent(Object source, List clusterMetrics) { super( source ); diff --git a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/event/metric/GroupMetricEvent.java b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/event/metric/GroupMetricEvent.java index 600daa46..24ce93ca 100644 --- a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/event/metric/GroupMetricEvent.java +++ b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/event/metric/GroupMetricEvent.java @@ -11,7 +11,7 @@ import java.util.List; @Getter public class GroupMetricEvent extends BaseMetricEvent{ - private List groupMetrics; + private final List groupMetrics; public GroupMetricEvent(Object source, List groupMetrics) { super( source ); diff --git a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/event/metric/PartitionMetricEvent.java b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/event/metric/PartitionMetricEvent.java index a2654ea5..0bc09b38 100644 --- a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/event/metric/PartitionMetricEvent.java +++ b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/event/metric/PartitionMetricEvent.java @@ -11,7 +11,7 @@ import java.util.List; @Getter public class PartitionMetricEvent extends BaseMetricEvent{ - private List partitionMetrics; + private final List partitionMetrics; public PartitionMetricEvent(Object source, List partitionMetrics) { super( source ); diff --git a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/event/metric/ReplicaMetricEvent.java b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/event/metric/ReplicaMetricEvent.java index bc4f0c10..9b71a69b 100644 --- a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/event/metric/ReplicaMetricEvent.java +++ b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/event/metric/ReplicaMetricEvent.java @@ -11,7 +11,7 @@ import java.util.List; @Getter public class ReplicaMetricEvent extends BaseMetricEvent{ - private List replicationMetrics; + private final List replicationMetrics; public ReplicaMetricEvent(Object source, List replicationMetrics) { super( source ); diff --git a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/event/metric/TopicMetricEvent.java b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/event/metric/TopicMetricEvent.java index 299afe01..359ef2a0 100644 --- a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/event/metric/TopicMetricEvent.java +++ b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/event/metric/TopicMetricEvent.java @@ -11,7 +11,7 @@ import java.util.List; @Getter public class TopicMetricEvent extends BaseMetricEvent{ - private List topicMetrics; + private final List topicMetrics; public TopicMetricEvent(Object source, List topicMetrics) { super( source ); diff --git a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/event/metric/ZookeeperMetricEvent.java b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/event/metric/ZookeeperMetricEvent.java index 19279d53..261440d6 100644 --- a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/event/metric/ZookeeperMetricEvent.java +++ b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/bean/event/metric/ZookeeperMetricEvent.java @@ -11,7 +11,7 @@ import java.util.List; @Getter public class ZookeeperMetricEvent extends BaseMetricEvent { - private List zookeeperMetrics; + private final List zookeeperMetrics; public ZookeeperMetricEvent(Object source, List zookeeperMetrics) { super( source );