public class AuthnzServerAuthorizer
extends io.confluent.security.authorizer.EmbeddedAuthorizer
Modifier and Type | Class and Description |
---|---|
static class |
AuthnzServerAuthorizer.AuthnzServerInfo |
Constructor and Description |
---|
AuthnzServerAuthorizer() |
Modifier and Type | Method and Description |
---|---|
protected io.confluent.security.authorizer.Action |
actionForAuthorizeByResourceType(io.confluent.security.authorizer.RequestContext requestContext,
io.confluent.security.authorizer.Operation op,
io.confluent.security.authorizer.ResourceType resourceType) |
protected io.confluent.security.authorizer.AuthorizeResult |
authorizeByResourceType(io.confluent.security.authorizer.RequestContext requestContext,
io.confluent.security.authorizer.Operation op,
io.confluent.security.authorizer.ResourceType resourceType) |
void |
configure(Map<String,?> configs) |
void |
configureServerInfo(org.apache.kafka.server.authorizer.internals.ConfluentAuthorizerServerInfo serverInfo) |
protected CompletableFuture<Void> |
futureOrTimeout(CompletableFuture<Void> readyFuture,
Duration timeout) |
protected org.apache.kafka.common.metrics.Metrics |
metrics() |
protected org.apache.kafka.common.utils.Time |
metricsTime() |
protected boolean |
ready() |
CompletableFuture<Void> |
start(org.apache.kafka.server.authorizer.internals.ConfluentAuthorizerServerInfo serverInfo,
Map<String,?> interBrokerListenerConfigs,
Runnable initTask) |
CompletableFuture<Void> |
start(org.apache.kafka.common.metrics.Metrics metrics,
Map<String,?> clientConfigs) |
accessRuleProvider, accessRuleProviders, auditLogProvider, authorize, close, configureProviders, groupProvider, isSuperUser, logAuditMessage, metadataProvider, scope, setupAuthorizerMetrics
public void configure(Map<String,?> configs)
configure
in interface org.apache.kafka.common.Configurable
configure
in class io.confluent.security.authorizer.EmbeddedAuthorizer
public CompletableFuture<Void> start(org.apache.kafka.common.metrics.Metrics metrics, Map<String,?> clientConfigs)
protected io.confluent.security.authorizer.AuthorizeResult authorizeByResourceType(io.confluent.security.authorizer.RequestContext requestContext, io.confluent.security.authorizer.Operation op, io.confluent.security.authorizer.ResourceType resourceType)
authorizeByResourceType
in class io.confluent.security.authorizer.EmbeddedAuthorizer
protected io.confluent.security.authorizer.Action actionForAuthorizeByResourceType(io.confluent.security.authorizer.RequestContext requestContext, io.confluent.security.authorizer.Operation op, io.confluent.security.authorizer.ResourceType resourceType)
actionForAuthorizeByResourceType
in class io.confluent.security.authorizer.EmbeddedAuthorizer
protected CompletableFuture<Void> futureOrTimeout(CompletableFuture<Void> readyFuture, Duration timeout)
futureOrTimeout
in class io.confluent.security.authorizer.EmbeddedAuthorizer
protected boolean ready()
ready
in class io.confluent.security.authorizer.EmbeddedAuthorizer
protected org.apache.kafka.common.utils.Time metricsTime()
metricsTime
in class io.confluent.security.authorizer.EmbeddedAuthorizer
protected org.apache.kafka.common.metrics.Metrics metrics()
metrics
in class io.confluent.security.authorizer.EmbeddedAuthorizer
public void configureServerInfo(org.apache.kafka.server.authorizer.internals.ConfluentAuthorizerServerInfo serverInfo)
configureServerInfo
in class io.confluent.security.authorizer.EmbeddedAuthorizer
public CompletableFuture<Void> start(org.apache.kafka.server.authorizer.internals.ConfluentAuthorizerServerInfo serverInfo, Map<String,?> interBrokerListenerConfigs, Runnable initTask)
start
in class io.confluent.security.authorizer.EmbeddedAuthorizer