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/07/02 02:39:46 UTC
[pulsar] branch branch-2.9 updated (0d303c89dfc -> 1ee4e29e0c7)
This is an automated email from the ASF dual-hosted git repository.
mattisonchao pushed a change to branch branch-2.9
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 0d303c89dfc [Transaction] Set TC state is Ready after open MLTransactionMetadataStore completely. (#13957)
add 1ee4e29e0c7 [branch-2.9]add message ack rate (#16146)
No new revisions were added by this update.
Summary of changes:
.../org/apache/pulsar/broker/service/Consumer.java | 39 +++++--
.../apache/pulsar/broker/service/ServerCnx.java | 1 +
.../pulsar/broker/service/StreamingStats.java | 1 +
.../nonpersistent/NonPersistentSubscription.java | 1 +
.../service/nonpersistent/NonPersistentTopic.java | 3 +
.../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 | 2 +
.../pulsar/broker/stats/prometheus/TopicStats.java | 5 +
.../pulsar/broker/stats/ConsumerStatsTest.java | 123 ++++++++++++++++++++-
.../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, 194 insertions(+), 15 deletions(-)