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

[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


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

commit 542a98ae53407e8ff128409d132f2173fa7daf13
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>
---
 .../broker/authorization/PulsarAuthorizationProvider.java     | 11 -----------
 1 file changed, 11 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 399ecc4a9f0..765835fde33 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
@@ -141,10 +141,6 @@ public class PulsarAuthorizationProvider implements 
AuthorizationProvider {
                         }
                     }
                     return checkAuthorization(topicName, role, 
AuthAction.consume);
-                }).exceptionally(ex -> {
-                    log.warn("Client with Role - {} failed to get permissions 
for topic - {}. {}", role, topicName,
-                            ex.getMessage());
-                    return null;
                 });
     }
 
@@ -167,13 +163,6 @@ public class PulsarAuthorizationProvider implements 
AuthorizationProvider {
                         return CompletableFuture.completedFuture(true);
                     }
                     return canConsumeAsync(topicName, role, 
authenticationData, null);
-                }).exceptionally(ex -> {
-                    if (log.isDebugEnabled()) {
-                        log.debug("Topic [{}] Role [{}] exception occurred 
while trying to check produce/consume"
-                                + " permissions. {}", topicName.toString(), 
role, ex.getMessage());
-
-                    }
-                    throw FutureUtil.wrapToCompletionException(ex);
                 });
     }