public class EmbeddedAuthorizer extends Object implements Authorizer
Modifier and Type | Class and Description |
---|---|
static class |
EmbeddedAuthorizer.AuthorizerMetrics |
Constructor and Description |
---|
EmbeddedAuthorizer() |
Modifier and Type | Method and Description |
---|---|
AccessRuleProvider |
accessRuleProvider(String providerName) |
List<AccessRuleProvider> |
accessRuleProviders() |
org.apache.kafka.server.audit.AuditLogProvider |
auditLogProvider() |
List<AuthorizeResult> |
authorize(RequestContext requestContext,
List<Action> actions)
Performs authorization for each of the provided `actions` and returns the result of each
authorization.
|
static void |
clearAuthorizerProvidersMap() |
void |
close() |
void |
configure(Map<String,?> configs) |
void |
configureServerInfo(org.apache.kafka.server.authorizer.internals.ConfluentAuthorizerServerInfo serverInfo) |
GroupProvider |
groupProvider() |
MetadataProvider |
metadataProvider() |
static void |
removeFromAuthorizerProvidersMap(String sessionUuid) |
CompletableFuture<Void> |
start(org.apache.kafka.server.authorizer.internals.ConfluentAuthorizerServerInfo serverInfo,
Runnable initTask) |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
authorize, authorize, authorize
public void configure(Map<String,?> configs)
configure
in interface org.apache.kafka.common.Configurable
public void configureServerInfo(org.apache.kafka.server.authorizer.internals.ConfluentAuthorizerServerInfo serverInfo)
public List<AuthorizeResult> authorize(RequestContext requestContext, List<Action> actions)
Authorizer
authorize
in interface Authorizer
requestContext
- Request context including principal and additional context for auditingactions
- List of actions being authorized including the resource and operation
for each action.public GroupProvider groupProvider()
public AccessRuleProvider accessRuleProvider(String providerName)
public MetadataProvider metadataProvider()
public List<AccessRuleProvider> accessRuleProviders()
public org.apache.kafka.server.audit.AuditLogProvider auditLogProvider()
public CompletableFuture<Void> start(org.apache.kafka.server.authorizer.internals.ConfluentAuthorizerServerInfo serverInfo, Runnable initTask)
public void close()
close
in interface Closeable
close
in interface AutoCloseable
public static void removeFromAuthorizerProvidersMap(String sessionUuid)
public static void clearAuthorizerProvidersMap()