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 |
---|---|
void |
configure(Map<String,?> configs) |
void |
configureServerInfo(org.apache.kafka.server.authorizer.internals.ConfluentAuthorizerServerInfo serverInfo) |
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, clearAuthorizerProvidersMap, close, groupProvider, metadataProvider, removeFromAuthorizerProvidersMap
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)
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