Repository navigation
[Feature] Add two metrics rocketmq_active_topic_number and rocketmq_active_subscription_number #8223
Description
Is Your Feature Request Related to a Problem?
The existing observable system of this project lacks broker-side monitoring of the number of topic and subscription group.
Describe the Solution You'd Like
Add two metrics rocketmq_active_topic_number and rocketmq_active_subscription_number as following:
| Type | Name | Unit | Description | Label |
|---|---|---|---|---|
| Gauge | rocketmq_active_topic_number | count | The number of current topics | cluster,node_type,node_id |
| Gauge | rocketmq_active_subscription_number | count | The number of current subscription group | cluster,node_type,node_id |
Describe Alternatives You've Considered
-
Anticipated use of gauge type metric
Gauge: A metric that can be incremented or decremented, used to describe the current state of a particular indicator, such as the remaining system memory. -
Add metric variables to the BrokerMetricsManager class:
activeTopicNum,activeSubGroupNum -
Add corresponding constants to the BrokerMetricsConstant class
-
Build corresponding metrics inside the
initStatsMetricsmethod of the BrokerMetricsManager class -
Write a gauge update callback function that refreshes periodically
a. Callthis.brokerController.topicConfigManager.getTopicConfigTable().size()to retrieve the number of topics.
b. CallbrokerController.getSubscriptionGroupManager().getSubscriptionGroupTable().size()to obtain the number of subscription groups.
Additional Context
No response
Activity
humkum commentedon May 30, 2024
Here you can only get the total number of topics and subscription groups, but cannot determine whether these topics and subscription groups are active. Would it be more accurate to call it rocketmq_total_topic_number & rocketmq_total_subscription_number?
[ISSUE #8223] Add two metrics rocketmq_topic_number and rocketmq_cons…
[ISSUE #8223] Add two metrics rocketmq_topic_number and rocketmq_cons…