Fix

conf/broker.conf

@@ -474,8 +474,8 @@ maxConcurrentTopicLoadRequest=5000
 # Max concurrent non-persistent message can be processed per connection
 maxConcurrentNonPersistentMessagePerConnection=1000
 
-# Number of worker threads to serve non-persistent topic
-numWorkerThreadsForNonPersistentTopic=
+# Number of worker threads to serve topic ordered executor
+topicOrderedExecutorThreadNum=
 
 # Enable broker to load persistent topics
 enablePersistentTopics=true
@@ -1816,3 +1816,7 @@ persistentUnackedRangesWithMultipleEntriesEnabled=false
 
 # Deprecated - Use managedLedgerCacheEvictionIntervalMs instead
 managedLedgerCacheEvictionFrequency=0
+
+# Number of worker threads to serve non-persistent topic
+# Deprecated - use topicOrderedExecutorThreadNum instead.
+numWorkerThreadsForNonPersistentTopic=

conf/standalone.conf

@@ -281,8 +281,8 @@ maxConcurrentTopicLoadRequest=5000
 # Max concurrent non-persistent message can be processed per connection
 maxConcurrentNonPersistentMessagePerConnection=1000
 
-# Number of worker threads to serve non-persistent topic
-numWorkerThreadsForNonPersistentTopic=8
+# Number of worker threads to serve topic ordered executor
+topicOrderedExecutorThreadNum=8
 
 # Enable broker to load persistent topics
 enablePersistentTopics=true
@@ -1201,6 +1201,10 @@ functionsWorkerEnablePackageManagement=false
 
 # These settings are left here for compatibility
 
+# Number of worker threads to serve non-persistent topic
+# Deprecated - use topicOrderedExecutorThreadNum instead.
+numWorkerThreadsForNonPersistentTopic=8
+
 # Zookeeper session timeout in milliseconds
 # Deprecated: use metadataStoreSessionTimeoutMillis
 zooKeeperSessionTimeoutMillis=-1

deployment/terraform-ansible/templates/broker.conf

@@ -332,8 +332,8 @@ maxConcurrentTopicLoadRequest=5000
 # Max concurrent non-persistent message can be processed per connection
 maxConcurrentNonPersistentMessagePerConnection=1000
 
-# Number of worker threads to serve non-persistent topic
-numWorkerThreadsForNonPersistentTopic=8
+# Number of worker threads to serve topic ordered executor
+topicOrderedExecutorThreadNum=8
 
 # Enable broker to load persistent topics
 enablePersistentTopics=true
@@ -1127,6 +1127,10 @@ fileSystemURI=
 
 ### --- Deprecated config variables --- ###
 
+# Number of worker threads to serve non-persistent topic
+# Deprecated - use topicOrderedExecutorThreadNum instead.
+numWorkerThreadsForNonPersistentTopic=8
+
 # Deprecated. Use configurationStoreServers
 globalZookeeperServers={{ zookeeper_servers }}
 

pulsar-broker/src/test/java/org/apache/pulsar/broker/EmbeddedPulsarCluster.java

@@ -112,7 +112,7 @@ private ServiceConfiguration getConf() {
         conf.setWebServicePort(Optional.of(0));
         conf.setNumExecutorThreadPoolSize(1);
         conf.setNumCacheExecutorThreadPoolSize(1);
-        conf.setNumWorkerThreadsForNonPersistentTopic(1);
+        conf.setTopicOrderedExecutorThreadNum(1);
         conf.setNumIOThreads(1);
         conf.setNumOrderedExecutorThreads(1);
         conf.setBookkeeperClientNumWorkerThreads(1);