This is an automated email from the ASF dual-hosted git repository.
lizhanhui pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
from 630abced4 Remove unnecessary retries in sendMessageBack (#5501)
add a5b40fba1 add client connection and consume lag metrics (#5505)
No new revisions were added by this update.
Summary of changes:
.../broker/metrics/BrokerMetricsConstant.java | 13 +
.../broker/metrics/BrokerMetricsManager.java | 184 +++++++++++-
.../rocketmq/broker/metrics/ConsumerAttr.java | 43 ++-
.../broker/metrics/ConsumerLagCalculator.java | 328 +++++++++++++++++++++
.../rocketmq/broker/metrics/ProducerAttr.java | 34 +--
5 files changed, 552 insertions(+), 50 deletions(-)
copy common/src/main/java/org/apache/rocketmq/common/TopicQueueId.java =>
broker/src/main/java/org/apache/rocketmq/broker/metrics/ConsumerAttr.java (58%)
create mode 100644
broker/src/main/java/org/apache/rocketmq/broker/metrics/ConsumerLagCalculator.java
copy common/src/main/java/org/apache/rocketmq/common/TopicQueueId.java =>
broker/src/main/java/org/apache/rocketmq/broker/metrics/ProducerAttr.java (58%)
