[pulsar] 03/04: [improve][broker] Avoid using `common-pool` when run async method. (#17229)

[technoboy]

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

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

commit 5c2155bf9961e25c829e3229834e433d7a8a8fd9
Author: Qiang Zhao <mattisonc...@apache.org>
AuthorDate: Wed Aug 24 09:51:43 2022 +0800

    [improve][broker] Avoid using `common-pool` when run async method. (#17229)
---
 .../src/main/java/org/apache/pulsar/broker/service/BrokerService.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 5d3a034b21c..f19be58f958 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
@@ -3019,7 +3019,7 @@ public class BrokerService implements Closeable {
         }
         return pulsarService.getPulsarResources().getNamespaceResources()
                 .getPoliciesAsync(topicName.getNamespaceObject())
-                .thenComposeAsync(optPolicies -> {
+                .thenCompose(optPolicies -> {
                     if (optPolicies.isPresent() && optPolicies.get().deleted) {
                         // We can return the completed future directly if the 
namespace is already deleted.
                         return CompletableFuture.completedFuture(null);