[pulsar] branch master updated: [fix][broker] Replace sync method in async call chain of internalSetBacklogQuota (#19398)

[lhotari]

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 81af293c842 [fix][broker] Replace sync method in async call chain of 
internalSetBacklogQuota (#19398)
81af293c842 is described below

commit 81af293c842c1fc7f42e13ac4203f287e4b619bb
Author: Lari Hotari <lhot...@users.noreply.github.com>
AuthorDate: Thu Feb 2 16:48:48 2023 +0200

    [fix][broker] Replace sync method in async call chain of 
internalSetBacklogQuota (#19398)
---
 .../java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java
index ee349580df3..efe2c31918a 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java
@@ -3346,7 +3346,7 @@ public class PersistentTopicsBase extends AdminResource {
                 ? BacklogQuota.BacklogQuotaType.destination_storage : 
backlogQuotaType;
 
         return validateTopicPolicyOperationAsync(topicName, 
PolicyName.BACKLOG, PolicyOperation.WRITE)
-                .thenAccept(__ -> validatePoliciesReadOnlyAccess())
+                .thenCompose(__ -> validatePoliciesReadOnlyAccessAsync())
                 .thenCompose(__ -> getTopicPoliciesAsyncWithRetry(topicName, 
isGlobal))
                 .thenCompose(op -> {
                     TopicPolicies topicPolicies = 
op.orElseGet(TopicPolicies::new);