You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by lh...@apache.org on 2026/09/23 12:36:59 UTC

(pulsar) 09/21: [improve][broker] Disable subscription-thread dispatch by default (#26578)

This is an automated email from the ASF dual-hosted git repository.

lhotari pushed a commit to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git

commit c67607ee22caa8e7f97c0a56b7b258886418dccd
Author: Lari Hotari <lh...@users.noreply.github.com>
AuthorDate: Mon Sep 14 22:59:57 2026 +0300

    [improve][broker] Disable subscription-thread dispatch by default (#26578)
    
    (cherry picked from commit c613d254c271154530a3fb5ebe4fdecf540fbef9)
---
 conf/broker.conf                                                        | 2 +-
 .../src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java    | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/conf/broker.conf b/conf/broker.conf
index f582f12cc393..c38e9fb1142f 100644
--- a/conf/broker.conf
+++ b/conf/broker.conf
@@ -509,7 +509,7 @@ dispatchThrottlingOnNonBacklogConsumerEnabled=true
 dispatcherMaxReadBatchSize=100
 
 # Dispatch messages and execute broker side filters in a per-subscription thread
-dispatcherDispatchMessagesInSubscriptionThread=true
+dispatcherDispatchMessagesInSubscriptionThread=false
 
 # Max size in bytes of entries to read from bookkeeper. By default it is 5MB.
 dispatcherMaxReadSizeBytes=5242880
diff --git a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java
index ea8c23696617..84154cf8842d 100644
--- a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java
+++ b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java
@@ -1308,7 +1308,7 @@ public class ServiceConfiguration implements PulsarConfiguration {
             category = CATEGORY_SERVER,
             doc = "Dispatch messages and execute broker side filters in a per-subscription thread"
     )
-    private boolean dispatcherDispatchMessagesInSubscriptionThread = true;
+    private boolean dispatcherDispatchMessagesInSubscriptionThread = false;
 
     @FieldContext(
         dynamic = false,