Fixes # throwable exception not thrown.
* Fixes # throwable exception not thrown.
Motivation
I found some throwable exception that not thrown, maybe it's a bug.
* Fixed #delete useless exception
@@ -40,7 +40,6 @@ import org.apache.pulsar.common.policies.data.Policies;
import org.apache.pulsar.common.policies.data.PolicyName;
import org.apache.pulsar.common.policies.data.PolicyOperation;
import org.apache.pulsar.common.policies.data.TenantInfo;
-import org.apache.pulsar.common.policies.data.TenantInfoImpl;
import org.apache.pulsar.common.policies.data.TenantOperation;
import org.apache.pulsar.common.policies.data.TopicOperation;
import org.apache.pulsar.common.util.FutureUtil;
@@ -123,9 +122,6 @@ public class PulsarAuthorizationProvider implements AuthorizationProvider {
.getSubscriptionAuthentication().get(subscription);
if (roles != null && !roles.isEmpty() && !roles.contains(role)) {
log.warn("[{}] is not authorized to subscribe on {}-{}", role, topicName, subscription);
- PulsarServerException ex = new PulsarServerException(
- String.format("%s is not authorized to access subscription %s on topic %s", role,
- subscription, topicName));
permissionFuture.complete(false);
return;
}
