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

修复Offset单位错误问题

Browse Source
This commit is contained in:
zengqiao
2022-09-06 15:19:29 +08:00
parent 93cbfa0b1f
commit a7cbb76655
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/metrics/PartitionMetricVersionItems.java
View File

@@ -37,12 +37,12 @@ public class PartitionMetricVersionItems extends BaseMetricVersionMetric {
// LogEndOffset 指标 // LogEndOffset 指标
itemList.add( buildAllVersionsItem() itemList.add( buildAllVersionsItem()
.name(PARTITION_METRIC_LOG_END_OFFSET).unit("条").desc("Partition中Leader副本的LogEndOffset") .name(PARTITION_METRIC_LOG_END_OFFSET).unit("").desc("Partition中Leader副本的LogEndOffset")
.extendMethod(PARTITION_METHOD_GET_OFFSET_RELEVANT_METRICS)); .extendMethod(PARTITION_METHOD_GET_OFFSET_RELEVANT_METRICS));
// LogStartOffset 指标 // LogStartOffset 指标
itemList.add( buildAllVersionsItem() itemList.add( buildAllVersionsItem()
.name(PARTITION_METRIC_LOG_START_OFFSET).unit("条").desc("Partition中Leader副本的LogStartOffset") .name(PARTITION_METRIC_LOG_START_OFFSET).unit("").desc("Partition中Leader副本的LogStartOffset")
.extendMethod(PARTITION_METHOD_GET_OFFSET_RELEVANT_METRICS)); .extendMethod(PARTITION_METHOD_GET_OFFSET_RELEVANT_METRICS));
// Messages // Messages

4
km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/version/metrics/ReplicaMetricVersionItems.java
View File

@@ -36,13 +36,13 @@ public class ReplicaMetricVersionItems extends BaseMetricVersionMetric {
// LogEndOffset 指标 // LogEndOffset 指标
itemList.add(buildAllVersionsItem() itemList.add(buildAllVersionsItem()
.name(REPLICATION_METRIC_LOG_END_OFFSET).unit("条").desc("副本的LogEndOffset") .name(REPLICATION_METRIC_LOG_END_OFFSET).unit("").desc("副本的LogEndOffset")
.extend(buildJMXMethodExtend(REPLICATION_METHOD_GET_METRIC_FROM_JMX ) .extend(buildJMXMethodExtend(REPLICATION_METHOD_GET_METRIC_FROM_JMX )
.jmxObjectName( JMX_LOG_LOG_END_OFFSET ).jmxAttribute(VALUE))); .jmxObjectName( JMX_LOG_LOG_END_OFFSET ).jmxAttribute(VALUE)));
// LogStartOffset 指标 // LogStartOffset 指标
itemList.add(buildAllVersionsItem() itemList.add(buildAllVersionsItem()
.name( REPLICATION_METRIC_LOG_START_OFFSET ).unit("条").desc("副本的LogStartOffset") .name( REPLICATION_METRIC_LOG_START_OFFSET ).unit("").desc("副本的LogStartOffset")
.extend(buildJMXMethodExtend(REPLICATION_METHOD_GET_METRIC_FROM_JMX ) .extend(buildJMXMethodExtend(REPLICATION_METHOD_GET_METRIC_FROM_JMX )
.jmxObjectName( JMX_LOG_LOG_START_OFFSET ).jmxAttribute(VALUE))); .jmxObjectName( JMX_LOG_LOG_START_OFFSET ).jmxAttribute(VALUE)));