This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from bf71d4d55ee [fix][sec] Upgrade Jetty to 9.4.58.v20250814 to address
CVE-2025-5115 (#24897)
new 4e095a60660 [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 44b55f9eaa4 [improve][broker] PIP-434: add configurations to
broker.conf (#24800)
new 324fadd1de9 [fix][test] Fix flaky
LookupPropertiesTest.testConcurrentLookupProperties (#24854)
new af09a3a075f [improve][broker] Part-2 of PIP-434: Use
ServerCnxThrottleTracker, instead of modifying channel.readable directly
(#24799)
new 2d7ce2600f7 [fix][test] Stabilize PublishRateLimiterOverconsumingTest
by aligning measurement and using adjacent 2-sec averages (#24864)
new 74c366c7a9c [fix][broker] Flaky-test:
TopicTransactionBufferTest.testMessagePublishInOrder (#24826)
new 3ecbe8c15b4 [fix][broker] Stop to retry to read entries if the
replicator has terminated (#24880)
new 5bdc5aa589c [improve][broker]Skip to mark delete if the target
position of expira… (#24881)
new 42e02a866df [fix][test]
BacklogQuotaManagerTest.backlogsAgeMetricsNoPreciseWithoutBacklogQuota handle
empty /metrics scrape (#24887)
new fb1b2a5115e [improve][client]Add null check for Pulsar client clock
configuration (#24848)
new e169f8d3e8c [fix][test] Made
ProtobufSchemaTest.testParsingInfoProperty order-independent (#24807)
new ec894557208 [fix][test]fix flaky
SimpleProducerConsumerTest.testReceiveAsyncCompletedWhenClosing (#24858)
new 8b3245f25fa [fix][broker] Fix totalAvailablePermits not reduced when
removing consumer from non-persistent dispatcher (#24885)
new 61f6fcd9e2d [improve][broker] Reduce the broker close time to avoid
useless wait for event loop shutdown (#24895)
new 18aa9eac63f [fix][test] Fix flaky
ReplicatorTest.testResumptionAfterBacklogRelaxed (#24904)
The 15 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 ++
.../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 +
.../persistent/PersistentMessageExpiryMonitor.java | 4 +
.../service/persistent/PersistentReplicator.java | 12 +-
.../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 ++
.../PersistentReplicatorInflightTaskTest.java | 41 ++
.../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 +-
42 files changed, 1688 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
