[pulsar] branch branch-2.10 updated: [fix][authorization] Fix the return value of canConsumeAsync (#19412)

[xiangying]

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

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


The following commit(s) were added to refs/heads/branch-2.10 by this push:
     new b28d796119b [fix][authorization] Fix the return value of 
canConsumeAsync (#19412)
b28d796119b is described below

commit b28d796119b8cc328b091d806536205158e57d95
Author: Zixuan Liu <node...@gmail.com>
AuthorDate: Tue Feb 7 17:49:55 2023 +0800

    [fix][authorization] Fix the return value of canConsumeAsync (#19412)
    
    Signed-off-by: Zixuan Liu <node...@gmail.com>
    (cherry picked from commit 016e7f0af997788d0514ca64e2c5c1bd9f506863)
---
 .../pulsar/broker/authorization/PulsarAuthorizationProvider.java     | 5 -----
 1 file changed, 5 deletions(-)

diff --git 
a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/PulsarAuthorizationProvider.java
 
b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/PulsarAuthorizationProvider.java
index fa7d885f44b..2201ee3031c 100644
--- 
a/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/PulsarAuthorizationProvider.java
+++ 
b/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/PulsarAuthorizationProvider.java
@@ -144,11 +144,6 @@ public class PulsarAuthorizationProvider implements 
AuthorizationProvider {
                 // check namespace and topic level consume-permissions
                 checkAuthorization(topicName, role, 
AuthAction.consume).thenAccept(isAuthorized -> {
                     permissionFuture.complete(isAuthorized);
-                }).exceptionally(ex -> {
-                    log.warn("Client with Role - {} failed to get permissions 
for topic - {}. {}", role, topicName,
-                            ex.getMessage());
-                    permissionFuture.completeExceptionally(ex);
-                    return null;
                 });
             }).exceptionally(ex -> {
                 log.warn("Client with Role - {} failed to get permissions for 
topic - {}. {}", role, topicName,