This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch branch-3.2
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from f5c853a4e8a [fix] [broker] Prevent long deduplication cursor backlog
so that topic loading wouldn't timeout (#22479)
new aa5af23abca [improve][test] Replace usage of curl in Java test and fix
stream leaks (#22463)
new f036250817d [improve][broker] Improve Gzip compression, allow
excluding specific paths or disabling it (#22370)
new 8182edd7b50 [fix][broker] Optimize /metrics, fix unbounded request
queue issue and fix race conditions in metricsBufferResponse mode (#22494)
The 3 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:
conf/proxy.conf | 6 +-
.../apache/pulsar/broker/ServiceConfiguration.java | 13 +
.../PrometheusMetricsGeneratorUtils.java | 2 +-
.../stats/prometheus/PrometheusMetricsServlet.java | 149 +++++++---
.../apache/pulsar/broker/web/GzipHandlerUtil.java | 48 +++
.../org/apache/pulsar/broker/stats/TimeWindow.java | 94 ------
.../org/apache/pulsar/broker/stats/WindowWrap.java | 56 ----
.../broker/stats/prometheus/MetricsExports.java | 68 +++++
.../stats/prometheus/PrometheusMetricStreams.java | 2 +-
.../prometheus/PrometheusMetricsGenerator.java | 328 ++++++++++++---------
.../prometheus/PulsarPrometheusMetricsServlet.java | 140 ++++++++-
.../pulsar/broker/stats/prometheus/TopicStats.java | 12 +-
.../org/apache/pulsar/broker/web/WebService.java | 10 +-
.../apache/pulsar/PrometheusMetricsTestUtil.java | 84 ++++++
.../persistent/BucketDelayedDeliveryTest.java | 6 +-
.../service/persistent/PersistentTopicTest.java | 4 +-
.../broker/service/schema/SchemaServiceTest.java | 4 +-
.../pulsar/broker/stats/ConsumerStatsTest.java | 4 +-
.../broker/stats/MetadataStoreStatsTest.java | 6 +-
.../pulsar/broker/stats/PrometheusMetricsTest.java | 114 +++----
.../pulsar/broker/stats/SubscriptionStatsTest.java | 4 +-
.../apache/pulsar/broker/stats/TimeWindowTest.java | 83 ------
.../broker/stats/TransactionMetricsTest.java | 18 +-
.../buffer/TransactionBufferClientTest.java | 4 +-
.../pendingack/PendingAckPersistentTest.java | 4 +-
.../apache/pulsar/broker/web/WebServiceTest.java | 73 +++--
.../pulsar/common/util/SimpleTextOutputStream.java | 16 +-
.../pulsar/proxy/server/AdminProxyHandler.java | 1 +
.../pulsar/proxy/server/ProxyConfiguration.java | 6 +
.../apache/pulsar/proxy/server/ProxyService.java | 3 +-
.../pulsar/proxy/server/ProxyServiceStarter.java | 40 ++-
31 files changed, 835 insertions(+), 567 deletions(-)
create mode 100644
pulsar-broker-common/src/main/java/org/apache/pulsar/broker/web/GzipHandlerUtil.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/TimeWindow.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/WindowWrap.java
create mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/MetricsExports.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/PrometheusMetricsTestUtil.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/stats/TimeWindowTest.java
