search

apache / rocketmq-exporter

Apache RocketMQ Prometheus Exporter
https://rocketmq.apache.org/
Apache License 2.0
295 stars 171 forks source link

rocketmq_producer_message_size has bug #63

Open Cczzzz opened 3 years ago

Cczzzz commented 3 years ago

try { //how many bytes has sent for the topic bsd = mqAdminExt.viewBrokerStatsData(masterAddr, BrokerStatsManager.TOPIC_PUT_SIZE, topic); String brokerIP = clusterInfo.getBrokerAddrTable().get(bd.getBrokerName()).getBrokerAddrs().get(MixAll.MASTER_ID); metricsService.getCollector().addTopicPutSizeMetric( bd.getCluster(), bd.getBrokerName(), brokerIP, topic, Utils.getFixedDouble(bsd.getStatsMinute().getTps()) );

in MetricsCollectTask 434 line，TopicPutSize use getTps

maixiaohai commented 3 years ago

@Cczzzz welcome submit a pr to fix it~