This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch branch-2.11
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 97518ee893c [fix] [broker] Prevent long deduplication cursor backlog
so that topic loading wouldn't timeout (#22479)
new 1522f0be11b [improve] [broker] Servlet support response compression
(#21667)
new ec652f85a00 [improve][test] Replace usage of curl in Java test and fix
stream leaks (#22463)
new 56999dcff11 [improve][broker] Improve Gzip compression, allow
excluding specific paths or disabling it (#22370)
new ef20f2bdcda Remove unused import in PendingAckHandleImpl
new 734c3f829ad [fix][broker] Optimize /metrics, fix unbounded request
queue issue and fix race conditions in metricsBufferResponse mode (#22494)
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:
conf/proxy.conf | 6 +-
.../apache/pulsar/broker/ServiceConfiguration.java | 13 +
.../PrometheusMetricsGeneratorUtils.java | 2 +-
.../stats/prometheus/PrometheusMetricsServlet.java | 152 +++++++---
.../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 | 13 +-
.../pendingack/impl/PendingAckHandleImpl.java | 1 -
.../org/apache/pulsar/broker/web/WebService.java | 20 +-
.../apache/pulsar/PrometheusMetricsTestUtil.java | 84 ++++++
.../service/persistent/PersistentTopicTest.java | 4 +-
.../broker/service/schema/SchemaServiceTest.java | 4 +-
.../pulsar/broker/stats/ConsumerStatsTest.java | 4 +-
.../pulsar/broker/stats/PrometheusMetricsTest.java | 108 ++++---
.../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 | 79 ++++-
.../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 | 36 ++-
30 files changed, 870 insertions(+), 531 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
