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 d3a79c2..9504fc8 100644 --- a/src/main/java/org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java +++ b/src/main/java/org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java @@ -90,7 +90,7 @@ public class RMQMetricsCollector extends Collector { //consumed message size(byte) for consumer-topic private ConcurrentHashMap groupGetSize = new ConcurrentHashMap<>(); //re-consumed message count for consumer-topic - private ConcurrentHashMap sendBackNums = new ConcurrentHashMap<>(); + private ConcurrentHashMap sendBackNums = new ConcurrentHashMap<>(); // group latency time private ConcurrentHashMap groupLatencyByTime = new ConcurrentHashMap<>(); @@ -500,7 +500,7 @@ private void collectGroupNums(List mfs) { mfs.add(groupGetSizeGauge); GaugeMetricFamily sendBackNumsGauge = new GaugeMetricFamily("rocketmq_send_back_nums", "SendBackNums", GROUP_NUMS_LABEL_NAMES); - for (Map.Entry entry : sendBackNums.entrySet()) { + for (Map.Entry entry : sendBackNums.entrySet()) { loadGroupNumsMetric(sendBackNumsGauge, entry); } mfs.add(sendBackNumsGauge); @@ -597,7 +597,7 @@ public void addGroupGetSizeMetric(String clusterName, String brokerName, String groupGetSize.put(new ConsumerMetric(clusterName, brokerName, topic, group), value); } - public void addSendBackNumsMetric(String clusterName, String brokerName, String topic, String group, double value) { + public void addSendBackNumsMetric(String clusterName, String brokerName, String topic, String group, long value) { sendBackNums.put(new ConsumerMetric(clusterName, brokerName, topic, group), value); } diff --git a/src/main/java/org/apache/rocketmq/exporter/task/MetricsCollectTask.java b/src/main/java/org/apache/rocketmq/exporter/task/MetricsCollectTask.java index 09665c2..1161e44 100644 --- a/src/main/java/org/apache/rocketmq/exporter/task/MetricsCollectTask.java +++ b/src/main/java/org/apache/rocketmq/exporter/task/MetricsCollectTask.java @@ -512,7 +512,7 @@ public void collectBrokerStatsTopic() { bd.getBrokerName(), topic, group, - Utils.getFixedDouble(bsd.getStatsMinute().getTps())); + bsd.getStatsMinute().getSum()); } catch (MQClientException ex) { if (ex.getResponseCode() == ResponseCode.SYSTEM_ERROR) { log.error(String.format("SNDBCK_PUT_NUMS-error, topic=%s, group=%s, master broker=%s, %s", topic, group, masterAddr, ex.getErrorMessage()));