This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch branch-2.10
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 7c88bd1b20b [fix][security] Add timeout of sync methods and avoid call
sync method for AuthoriationService (#15694)
new 49087fa4fb7 [Function] provide default error handler for function log
appender (#15728)
new 99cc4a96475 non-persistent topic metrics (#13827)
new 9796eb40bc6 [broker][monitoring] add message ack rate metric for
consumer (#15674)
new ff7762b21be Fix cherry-pick issue of using JDK10 API
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
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 | 4 ++
.../stats/prometheus/NamespaceStatsAggregator.java | 84 ++++++++++++++--------
.../pulsar/broker/stats/prometheus/TopicStats.java | 9 +++
.../pulsar/broker/stats/ConsumerStatsTest.java | 81 +++++++++++++++++++++
.../pulsar/broker/stats/PrometheusMetricsTest.java | 40 ++++++++++-
.../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 +
.../pulsar/functions/instance/LogAppender.java | 19 ++++-
20 files changed, 260 insertions(+), 40 deletions(-)
