You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@pulsar.apache.org by ma...@apache.org on 2022/06/13 01:56:56 UTC

[pulsar] branch master updated (8d8a19f786a -> 88b47e5e5ac)

This is an automated email from the ASF dual-hosted git repository.

mattisonchao pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


    from 8d8a19f786a [fix][admin] Fix typo in validation message (#16021)
     add 88b47e5e5ac [broker][monitoring] add message ack rate metric for consumer (#15674)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/pulsar/broker/service/Consumer.java | 24 +++++--
 .../apache/pulsar/broker/service/ServerCnx.java    |  1 +
 .../pulsar/broker/service/StreamingStats.java      |  1 +
 .../nonpersistent/NonPersistentSubscription.java   |  1 +
 .../service/nonpersistent/NonPersistentTopic.java  |  4 ++
 .../service/persistent/PersistentSubscription.java |  1 +
 .../broker/service/persistent/PersistentTopic.java |  3 +
 .../stats/prometheus/AggregatedConsumerStats.java  |  2 +
 .../stats/prometheus/AggregatedNamespaceStats.java |  2 +
 .../prometheus/AggregatedSubscriptionStats.java    |  2 +
 .../stats/prometheus/NamespaceStatsAggregator.java |  3 +
 .../pulsar/broker/stats/prometheus/TopicStats.java |  7 ++
 .../pulsar/broker/stats/ConsumerStatsTest.java     | 81 ++++++++++++++++++++++
 .../pulsar/common/policies/data/ConsumerStats.java |  5 ++
 .../common/policies/data/SubscriptionStats.java    |  5 ++
 .../policies/data/stats/ConsumerStatsImpl.java     |  6 ++
 .../policies/data/stats/SubscriptionStatsImpl.java |  5 ++
 pulsar-common/src/main/proto/PulsarApi.proto       |  3 +
 18 files changed, 151 insertions(+), 5 deletions(-)