This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 0fbcbb24039 [fix] [broker] Prevent long deduplication cursor backlog
so that topic loading wouldn't timeout (#22479)
new 93664d769cb [improve] [broker] Servlet support response compression
(#21667)
new 976399cb172 [improve][test] Replace usage of curl in Java test and fix
stream leaks (#22463)
new cdc5af15775 [improve][broker] Improve Gzip compression, allow
excluding specific paths or disabling it (#22370)
new 5f9d7c5d623 [fix][broker] Optimize /metrics, fix unbounded request
queue issue and fix race conditions in metricsBufferResponse mode (#22494)
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:
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 | 20 +-
.../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, 877 insertions(+), 535 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
