This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 6bc1e0d Source tarball: apply executable file permissions to shell
scripts (fixes #10917) (#11858)
new 875bfdf [python-client] Fixed crash when using Python logger (#10981)
new 71cc13b Add compacted topic metrics for TopicStats in CLI (#11564)
new a80f1e8 Expose compaction metrics to Prometheus (#11739)
new bbed232 [Broker] Refine topic level backlog quota policies warning
log (#11863)
new 19b2b69 Fix the checkstyle issue during the cherry-pick
The 5 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/PulsarService.java | 14 ++-
.../pulsar/broker/service/BacklogQuotaManager.java | 7 +-
.../pulsar/broker/service/BrokerService.java | 10 +-
.../broker/service/persistent/PersistentTopic.java | 52 +++++++--
.../broker/stats/metrics/AbstractMetrics.java | 23 +---
.../stats/prometheus/AggregatedNamespaceStats.java | 22 ++++
.../stats/prometheus/NamespaceStatsAggregator.java | 53 ++++++++-
.../pulsar/broker/stats/prometheus/TopicStats.java | 73 +++++++++++-
.../pulsar/compaction/CompactedTopicContext.java | 19 +--
.../pulsar/compaction/CompactedTopicImpl.java | 12 --
.../apache/pulsar/compaction/CompactionRecord.java | 130 +++++++++++++++++++++
.../org/apache/pulsar/compaction/Compactor.java | 29 +++--
.../apache/pulsar/compaction/CompactorMXBean.java | 24 ++--
.../pulsar/compaction/CompactorMXBeanImpl.java | 71 +++++++++++
.../pulsar/compaction/TwoPhaseCompactor.java | 24 +++-
.../pulsar/broker/stats/PrometheusMetricsTest.java | 93 +++++++++++++++
.../prometheus/AggregatedNamespaceStatsTest.java | 25 ++++
.../pulsar/compaction/CompactorMXBeanImplTest.java | 70 +++++++++++
.../apache/pulsar/compaction/CompactorTest.java | 21 +++-
.../data/{AuthAction.java => CompactionStats.java} | 25 ++--
.../pulsar/common/policies/data/TopicStats.java | 3 +
pulsar-client-cpp/python/src/config.cc | 65 +++++------
...atorStatsImpl.java => CompactionStatsImpl.java} | 39 ++++---
.../common/policies/data/stats/TopicStatsImpl.java | 6 +-
.../policies/data/PersistentTopicStatsTest.java | 4 +
site2/docs/reference-metrics.md | 10 ++
26 files changed, 761 insertions(+), 163 deletions(-)
copy
pulsar-common/src/main/java/org/apache/pulsar/common/intercept/InterceptException.java
=>
pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactedTopicContext.java
(63%)
create mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactionRecord.java
copy managed-ledger/src/main/java/org/apache/bookkeeper/mledger/Position.java
=>
pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactorMXBean.java
(71%)
create mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactorMXBeanImpl.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/compaction/CompactorMXBeanImplTest.java
copy
pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/policies/data/{AuthAction.java
=> CompactionStats.java} (65%)
copy
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/stats/{NonPersistentReplicatorStatsImpl.java
=> CompactionStatsImpl.java} (52%)
