You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by di...@apache.org on 2022/07/31 08:21:32 UTC
[rocketmq-exporter] branch master updated: remove lastupdateTimestamp for offset metric
This is an automated email from the ASF dual-hosted git repository.
dinglei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-exporter.git
The following commit(s) were added to refs/heads/master by this push:
new 4269107 remove lastupdateTimestamp for offset metric
new e19e65a Merge pull request #102 from cserwen/fix_offset
4269107 is described below
commit 4269107514aa1dd40e828c0e16010ecc2be3b74c
Author: cserwen <cs...@163.com>
AuthorDate: Tue May 17 10:38:53 2022 +0800
remove lastupdateTimestamp for offset metric
---
.../rocketmq/exporter/collector/RMQMetricsCollector.java | 10 ++++------
1 file changed, 4 insertions(+), 6 deletions(-)
diff --git a/src/main/java/org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java b/src/main/java/org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java
index ae87541..a233065 100644
--- a/src/main/java/org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java
+++ b/src/main/java/org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java
@@ -315,11 +315,11 @@ public class RMQMetricsCollector extends Collector {
private static final List<String> TOPIC_OFFSET_LABEL_NAMES = Arrays.asList(
- "cluster", "broker", "topic", "lastUpdateTimestamp"
+ "cluster", "broker", "topic"
);
private static final List<String> DLQ_TOPIC_OFFSET_LABEL_NAMES = Arrays.asList(
- "cluster", "broker", "group", "lastUpdateTimestamp"
+ "cluster", "broker", "group"
);
private void loadTopicOffsetMetric(GaugeMetricFamily family, Map.Entry<ProducerMetric, Double> entry) {
@@ -327,8 +327,7 @@ public class RMQMetricsCollector extends Collector {
Arrays.asList(
entry.getKey().getClusterName(),
entry.getKey().getBrokerName(),
- entry.getKey().getTopicName(),
- String.valueOf(entry.getKey().getLastUpdateTimestamp())
+ entry.getKey().getTopicName()
),
entry.getValue());
}
@@ -352,8 +351,7 @@ public class RMQMetricsCollector extends Collector {
Arrays.asList(
entry.getKey().getClusterName(),
entry.getKey().getBrokerName(),
- entry.getKey().getGroup(),
- String.valueOf(entry.getKey().getLastUpdateTimestamp())
+ entry.getKey().getGroup()
),
entry.getValue());
}