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 c3890dd5bf6032..c7486555c26db1 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 @@ -1199,7 +1199,7 @@ The delayed message index time step(in seconds) in per bucket snapshot segment, @FieldContext( category = CATEGORY_SERVER, doc = "Number of worker threads to serve topic ordered executor") - private int numWorkersTopicOrderedExecutor = Runtime.getRuntime().availableProcessors(); + private int topicOrderedExecutorThreadNum = Runtime.getRuntime().availableProcessors(); @FieldContext( category = CATEGORY_SERVER, @@ -3481,8 +3481,8 @@ public long getManagedLedgerCacheEvictionIntervalMs() { : Math.min(MAX_ML_CACHE_EVICTION_INTERVAL_MS, managedLedgerCacheEvictionIntervalMs); } - public int getNumWorkersTopicOrderedExecutor() { + public int getTopicOrderedExecutorThreadNum() { return numWorkerThreadsForNonPersistentTopic > 0 - ? numWorkerThreadsForNonPersistentTopic : numWorkersTopicOrderedExecutor; + ? numWorkerThreadsForNonPersistentTopic : topicOrderedExecutorThreadNum; } } diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java index 4b7792c1272658..af768b2f64c8a7 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java @@ -315,7 +315,7 @@ public BrokerService(PulsarService pulsar, EventLoopGroup eventLoopGroup) throws PersistentOfflineTopicStats>newBuilder().build(); this.topicOrderedExecutor = OrderedExecutor.newBuilder() - .numThreads(pulsar.getConfiguration().getNumWorkersTopicOrderedExecutor()) + .numThreads(pulsar.getConfiguration().getTopicOrderedExecutorThreadNum()) .name("broker-topic-workers").build(); final DefaultThreadFactory acceptorThreadFactory = new ExecutorProvider.ExtendedThreadFactory("pulsar-acceptor");