8x48/KnowStreaming
1
0
Fork 0
mirror of https://github.com/didi/KnowStreaming.git synced 2025-12-24 11:52:08 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

删除重复采集的指标

Browse Source
This commit is contained in:
zengqiao
2022-12-06 16:41:27 +08:00
parent 3a3141a361
commit 9735c4f885
1 changed files with 0 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/metrics/kafka/ClusterMetricVersionItems.java
View File

@@ -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_MIN_ISR_E = "PartitionMinISR_E";
public static final String CLUSTER_METRIC_PARTITION_URP = "PartitionURP"; 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_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_LEADER_MESSAGES = "LeaderMessages";
public static final String CLUSTER_METRIC_BYTES_IN = "BytesIn"; public static final String CLUSTER_METRIC_BYTES_IN = "BytesIn";
public static final String CLUSTER_METRIC_BYTES_IN_5_MIN = "BytesIn_min_5"; 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) .name(CLUSTER_METRIC_LEADER_MESSAGES).unit("条").desc("集群中leader总的消息条数").category(CATEGORY_CLUSTER)
.extend( buildMethodExtend( CLUSTER_METHOD_GET_MESSAGE_SIZE ))); .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 指标 // BytesInPerSec 指标
itemList.add( buildAllVersionsItem() itemList.add( buildAllVersionsItem()
.name(CLUSTER_METRIC_BYTES_IN).unit(BYTE_PER_SEC).desc("集群的每秒写入字节数").category(CATEGORY_CLUSTER) .name(CLUSTER_METRIC_BYTES_IN).unit(BYTE_PER_SEC).desc("集群的每秒写入字节数").category(CATEGORY_CLUSTER)