rocketmq-exporter icon indicating copy to clipboard operation
rocketmq-exporter copied to clipboard

rocketmq_producer_message_size has bug

Open Cczzzz opened this issue 3 years ago • 1 comments

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

Cczzzz avatar Aug 09 '21 11:08 Cczzzz

@Cczzzz welcome submit a pr to fix it~

maixiaohai avatar Aug 09 '21 12:08 maixiaohai