apache / apache/rocketmq-exporter
rocketmq_producer_message_size has bug
- Dominant language
- Java
- Stars
- 324
- Forks
- 178
- PR merge metrics
- No merged PRs in 30d
Description
` 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
Contributor guide
Assessment
This issue has not been assessed yet.