You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
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 initStatsMetrics method of the BrokerMetricsManager class
Write a gauge update callback function that refreshes periodically
a. Call this.brokerController.topicConfigManager.getTopicConfigTable().size() to retrieve the number of topics.
b. Call brokerController.getSubscriptionGroupManager().getSubscriptionGroupTable().size() to obtain the number of subscription groups.
Additional Context
No response
The text was updated successfully, but these errors were encountered:
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?
…umer_group_number (#8225)
* Add tow metric createTopicTime and createSubscriptionTime in broker
* roll back BrokerConfig.java
* Add metric view of createTopicTime and createSubscriptionTime in broker
* Add two metric rocketmq_active_topic_number and rocketmq_active_subscription_number
* Add two metric rocketmq_active_topic_number and rocketmq_active_subscription_number
Signed-off-by: 黄梓淇 <[email protected]>
---------
Signed-off-by: 黄梓淇 <[email protected]>
Co-authored-by: 黄梓淇 <[email protected]>
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:
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
initStatsMetrics
method of the BrokerMetricsManager classWrite a gauge update callback function that refreshes periodically
a. Call
this.brokerController.topicConfigManager.getTopicConfigTable().size()
to retrieve the number of topics.b. Call
brokerController.getSubscriptionGroupManager().getSubscriptionGroupTable().size()
to obtain the number of subscription groups.Additional Context
No response
The text was updated successfully, but these errors were encountered: