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/14 20:00:03 UTC

(pulsar) branch master updated: [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 master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new c613d254c271 [improve][broker] Disable subscription-thread dispatch by default (#26578)
c613d254c271 is described below

commit c613d254c271154530a3fb5ebe4fdecf540fbef9
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)
---
 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 06f252454e31..68e190e1553e 100644
--- a/conf/broker.conf
+++ b/conf/broker.conf
@@ -559,7 +559,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 3f31a6ca2284..cd90a17d2933 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
@@ -1626,7 +1626,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,