This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 14a731e Fixed possible deadlock in the initialization of
MLTransactionLog (#11194)
new 1663338 Make the compaction phase one loop timeout configurable
(#11206)
new 1b3582c Remove unused listener to reduce creating executor pool.
(#11215)
new 01f1596 [Issue 11067][pulsar-client] Fix bin/pulsar-client produce
not supporting v2 topic name through websocket (#11069)
new 0b27235 [Broker] Fix broker dispatch byte rate limiter. (#11135)
new aa290ae Fix init WebSocketService with ClusterData (#11234)
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/broker.conf | 4 +
.../apache/pulsar/broker/ServiceConfiguration.java | 7 +
.../broker/service/AbstractBaseDispatcher.java | 19 ++-
.../AbstractDispatcherMultipleConsumers.java | 5 +-
.../AbstractDispatcherSingleActiveConsumer.java | 6 +-
.../NonPersistentDispatcherMultipleConsumers.java | 5 +-
...onPersistentDispatcherSingleActiveConsumer.java | 6 +-
.../service/persistent/DispatchRateLimiter.java | 9 ++
.../PersistentDispatcherMultipleConsumers.java | 50 ++++---
.../PersistentDispatcherSingleActiveConsumer.java | 49 ++++---
...istentStreamingDispatcherMultipleConsumers.java | 10 +-
...entStreamingDispatcherSingleActiveConsumer.java | 11 +-
.../streamingdispatch/StreamingEntryReader.java | 4 +-
.../pulsar/compaction/TwoPhaseCompactor.java | 9 +-
.../client/api/MessageDispatchThrottlingTest.java | 42 ++----
.../apache/pulsar/compaction/CompactorTest.java | 14 ++
.../org/apache/pulsar/client/cli/CmdProduce.java | 23 ++-
.../apache/pulsar/client/cli/TestCmdProduce.java | 32 ++---
.../pulsar/proxy/server/ProxyServiceStarter.java | 117 +++++++++------
.../proxy/server/ProxyServiceStarterTest.java | 160 +++++++++++++++++++++
.../src/test/resources}/proxy.conf | 4 +-
.../impl/FileSystemManagedLedgerOffloader.java | 3 +-
22 files changed, 425 insertions(+), 164 deletions(-)
copy
pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/executor/MockClockTest.java
=>
pulsar-client-tools/src/test/java/org/apache/pulsar/client/cli/TestCmdProduce.java
(53%)
create mode 100644
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyServiceStarterTest.java
copy {conf => pulsar-proxy/src/test/resources}/proxy.conf (99%)
