From 9735c4f88522afed18ce719ee0b1715c4d87868b Mon Sep 17 00:00:00 2001 From: zengqiao Date: Tue, 6 Dec 2022 16:41:27 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=A0=E9=99=A4=E9=87=8D=E5=A4=8D=E9=87=87?= =?UTF-8?q?=E9=9B=86=E7=9A=84=E6=8C=87=E6=A0=87?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../version/metrics/kafka/ClusterMetricVersionItems.java | 6 ------ 1 file changed, 6 deletions(-) diff --git a/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/metrics/kafka/ClusterMetricVersionItems.java b/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/metrics/kafka/ClusterMetricVersionItems.java index 2c7408a9..c19bebc6 100644 --- a/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/metrics/kafka/ClusterMetricVersionItems.java +++ b/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/metrics/kafka/ClusterMetricVersionItems.java @@ -75,7 +75,6 @@ public class ClusterMetricVersionItems extends BaseMetricVersionMetric { public static final String CLUSTER_METRIC_PARTITION_MIN_ISR_E = "PartitionMinISR_E"; public static final String CLUSTER_METRIC_PARTITION_URP = "PartitionURP"; public static final String CLUSTER_METRIC_MESSAGES_IN = "MessagesIn"; - public static final String CLUSTER_METRIC_MESSAGES = "Messages"; public static final String CLUSTER_METRIC_LEADER_MESSAGES = "LeaderMessages"; public static final String CLUSTER_METRIC_BYTES_IN = "BytesIn"; public static final String CLUSTER_METRIC_BYTES_IN_5_MIN = "BytesIn_min_5"; @@ -293,11 +292,6 @@ public class ClusterMetricVersionItems extends BaseMetricVersionMetric { .name(CLUSTER_METRIC_LEADER_MESSAGES).unit("条").desc("集群中leader总的消息条数").category(CATEGORY_CLUSTER) .extend( buildMethodExtend( CLUSTER_METHOD_GET_MESSAGE_SIZE ))); - // Messages 指标 - itemList.add( buildAllVersionsItem() - .name(CLUSTER_METRIC_MESSAGES).unit("条").desc("集群总的消息条数").category(CATEGORY_CLUSTER) - .extend( buildMethodExtend( CLUSTER_METHOD_GET_MESSAGE_SIZE ))); - // BytesInPerSec 指标 itemList.add( buildAllVersionsItem() .name(CLUSTER_METRIC_BYTES_IN).unit(BYTE_PER_SEC).desc("集群的每秒写入字节数").category(CATEGORY_CLUSTER)