We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Describe the bug When the consumer is closed, the countOfOnlineConsumers of metrhc: rocketmq_group_diff won't be changed to 0.
countOfOnlineConsumers
rocketmq_group_diff
To Reproduce Steps to reproduce the behavior:
Expected behavior The value of countOfOnlineConsumers should be 0.
Screenshots
Additional context The root cause is that the following code.
rocketmq-exporter/src/main/java/org/apache/rocketmq/exporter/model/metrics/ConsumerTopicDiffMetric.java
Line 65 in 85cf905
ConsumerTopicDiffMetric
private String group; private String topic; private String countOfOnlineConsumers; private String msgModel; //0:broadcast, 1:cluster
It only calculates topic abd group. So when countOfOnlineConsumers changed, The new key will not be added.
topic
group
The text was updated successfully, but these errors were encountered:
Merge pull request #96 from cserwen/fix_hash_collision
44d6083
[ISSUE #95] hashCode() and equats() should calculate all fields
Successfully merging a pull request may close this issue.
Describe the bug
When the consumer is closed, the
countOfOnlineConsumers
of metrhc:rocketmq_group_diff
won't be changed to 0.To Reproduce
Steps to reproduce the behavior:
countOfOnlineConsumers
still is 1.Expected behavior
The value of
countOfOnlineConsumers
should be 0.Screenshots
Additional context
The root cause is that the following code.
rocketmq-exporter/src/main/java/org/apache/rocketmq/exporter/model/metrics/ConsumerTopicDiffMetric.java
Line 65 in 85cf905
The class
ConsumerTopicDiffMetric
has four fields:It only calculates
topic
abdgroup
. So when countOfOnlineConsumers changed, The new key will not be added.The text was updated successfully, but these errors were encountered: