Skip to content

Commit

Permalink
Remove KsqlException from KsqlAuthorizationProvider interface
Browse files Browse the repository at this point in the history
  • Loading branch information
spena committed Jun 27, 2019
1 parent b67f1c7 commit 8944526
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,7 @@ public void filter(final ContainerRequestContext requestContext) {
try {
authorizationProvider.checkEndpointAccess(user, method, path);
} catch (final Throwable t) {
log.warn(String.format("User:%s is denied access \"%s %s\"", user, method, path), t);
log.warn(String.format("User:%s is denied access to \"%s %s\"", user, method, path), t);
requestContext.abortWith(Errors.accessDenied(t.getMessage()));
}
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,8 +15,6 @@

package io.confluent.ksql.rest.server.security;

import io.confluent.ksql.util.KsqlException;

import java.security.Principal;

/**
Expand All @@ -28,8 +26,7 @@ public interface KsqlAuthorizationProvider {
*
* @param user The user who is requesting access to the endpoint
* @param method The endpoint method used, i.e. POST, GET, DELETE
* @param path The endpoint path to access, i.e. "/ksql", "/ksql/terminate", "/query"
* @throws KsqlException for access denied or any other authorization error
* @param path The endpoint path to access, i.e. "/ksql", "/ksql/terminate", "/query"*
*/
void checkEndpointAccess(Principal user, String method, String path) throws KsqlException;
void checkEndpointAccess(Principal user, String method, String path);
}

0 comments on commit 8944526

Please sign in to comment.