This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch branch-4.1
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from bb81dce0542 [fix][sec] Upgrade Jetty to 9.4.58.v20250814 to address
CVE-2025-5115 (#24897)
new 826e42b4942 [improve][broker] Part-1 of PIP-434: Expose Netty channel
configuration WRITE_BUFFER_WATER_MARK to pulsar conf and pause receive requests
when channel is unwritable (#24423)
new b0ebc4e81a8 [improve][broker] PIP-434: add configurations to
broker.conf (#24800)
new 0ed3f201a92 [fix][test] Fix flaky
LookupPropertiesTest.testConcurrentLookupProperties (#24854)
new 6fee2de1808 [improve][broker] Part-2 of PIP-434: Use
ServerCnxThrottleTracker, instead of modifying channel.readable directly
(#24799)
new 25aba4d3790 [fix][test] Stabilize PublishRateLimiterOverconsumingTest
by aligning measurement and using adjacent 2-sec averages (#24864)
new 98455d66c77 [fix][broker] Flaky-test:
TopicTransactionBufferTest.testMessagePublishInOrder (#24826)
new 85cc072cb80 [fix][test]
BacklogQuotaManagerTest.backlogsAgeMetricsNoPreciseWithoutBacklogQuota handle
empty /metrics scrape (#24887)
new 936b2400aaf [improve][client]Add null check for Pulsar client clock
configuration (#24848)
new f3d565e6185 [fix][test] Made
ProtobufSchemaTest.testParsingInfoProperty order-independent (#24807)
new 86f7363e309 [improve][io] Upgrade Debezium version to 3.2.4.Final
(#24896)
new 14bb250e0aa [fix][test]fix flaky
SimpleProducerConsumerTest.testReceiveAsyncCompletedWhenClosing (#24858)
new ef9fdfceac5 [fix][broker] Fix totalAvailablePermits not reduced when
removing consumer from non-persistent dispatcher (#24885)
new 5241bddd181 [improve][broker] Reduce the broker close time to avoid
useless wait for event loop shutdown (#24895)
new a99ef2bed8b [fix][test] Fix flaky
ReplicatorTest.testResumptionAfterBacklogRelaxed (#24904)
The 14 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/broker.conf | 31 ++
pom.xml | 2 +-
.../apache/pulsar/broker/ServiceConfiguration.java | 52 +++
.../resourcegroup/ResourceGroupPublishLimiter.java | 9 +-
.../pulsar/broker/service/AbstractTopic.java | 8 +-
.../pulsar/broker/service/BrokerService.java | 42 +-
.../org/apache/pulsar/broker/service/Producer.java | 24 -
.../broker/service/PublishRateLimiterImpl.java | 13 +-
.../broker/service/PulsarChannelInitializer.java | 2 +
.../apache/pulsar/broker/service/ServerCnx.java | 104 ++++-
.../broker/service/ServerCnxThrottleTracker.java | 481 +++++++++++++++++----
.../apache/pulsar/broker/service/TransportCnx.java | 17 +-
.../NonPersistentDispatcherMultipleConsumers.java | 2 +
.../buffer/impl/TopicTransactionBuffer.java | 7 +-
.../pulsar/utils/TimedSingleThreadRateLimiter.java | 83 ++++
.../broker/service/BacklogQuotaManagerTest.java | 45 +-
.../service/BrokerEventLoopShutdownTest.java | 71 +++
.../service/PublishRateLimiterDisableTest.java | 23 +-
.../PublishRateLimiterOverconsumingTest.java | 72 ++-
.../broker/service/PublishRateLimiterTest.java | 111 +++--
.../pulsar/broker/service/ReplicatorTest.java | 135 +++---
.../pulsar/broker/service/StandaloneTest.java | 6 +
.../service/TopicPublishRateThrottleTest.java | 31 ++
...ntStickyKeyDispatcherMultipleConsumersTest.java | 26 ++
.../broker/service/utils/ClientChannelHelper.java | 3 +-
.../buffer/utils/TransactionBufferTestImpl.java | 16 -
.../pulsar/client/api/LookupPropertiesTest.java | 3 +-
.../pulsar/client/api/MockBrokerService.java | 3 +-
.../api/PatternConsumerBackPressureTest.java | 99 +++++
.../client/api/SimpleProducerConsumerTest.java | 36 +-
.../common/naming/ServiceConfigurationTest.java | 7 +-
.../utils/TimedSingleThreadRateLimiterTest.java | 337 +++++++++++++++
.../configurations/pulsar_broker_test.conf | 7 +
.../pulsar_broker_test_standalone.conf | 8 +
.../pulsar/client/impl/ClientBuilderImpl.java | 1 +
.../client/impl/schema/ProtobufSchemaTest.java | 49 ++-
.../pulsar/common/protocol/PulsarDecoder.java | 4 +-
.../pulsar/common/protocol/PulsarHandler.java | 3 +-
.../pulsar/common/protocol/PulsarDecoderTest.java | 3 +-
.../pulsar/proxy/server/DirectProxyHandler.java | 3 +-
40 files changed, 1633 insertions(+), 346 deletions(-)
create mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/utils/TimedSingleThreadRateLimiter.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BrokerEventLoopShutdownTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/client/api/PatternConsumerBackPressureTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/utils/TimedSingleThreadRateLimiterTest.java
