io.confluent.security.auth.dataplane

Class AuthnzServerAuthorizer

java.lang.Object

io.confluent.security.authorizer.EmbeddedAuthorizer

io.confluent.security.auth.dataplane.AuthnzServerAuthorizer

All Implemented Interfaces:

io.confluent.security.authorizer.Authorizer, Closeable, AutoCloseable, org.apache.kafka.common.Configurable

public class AuthnzServerAuthorizer
extends io.confluent.security.authorizer.EmbeddedAuthorizer

Cross-component embedded authorizer that implements common authorization logic. This authorizer loads configured providers and uses them to perform authorization.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AuthnzServerAuthorizer.AuthnzServerInfo

Nested classes/interfaces inherited from class io.confluent.security.authorizer.EmbeddedAuthorizer

io.confluent.security.authorizer.EmbeddedAuthorizer.AuthorizerMetrics

Constructor Summary

Constructors

Constructor and Description
AuthnzServerAuthorizer()

Method Summary

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, Runnable initTask)
CompletableFuture<Void>	start(org.apache.kafka.common.metrics.Metrics metrics)

Methods inherited from class io.confluent.security.authorizer.EmbeddedAuthorizer

accessRuleProvider, accessRuleProviders, auditLogProvider, authorize, clearAuthorizerProvidersMap, close, groupProvider, metadataProvider, removeFromAuthorizerProvidersMap

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.confluent.security.authorizer.Authorizer

authorize, authorize, authorize

Constructor Detail

AuthnzServerAuthorizer

public AuthnzServerAuthorizer()

Method Detail

configure

public void configure(Map<String,?> configs)

Specified by:

configure in interface org.apache.kafka.common.Configurable

Overrides:

configure in class io.confluent.security.authorizer.EmbeddedAuthorizer

start

public CompletableFuture<Void> start(org.apache.kafka.common.metrics.Metrics metrics)

configureServerInfo

public void configureServerInfo(org.apache.kafka.server.authorizer.internals.ConfluentAuthorizerServerInfo serverInfo)

Overrides:

configureServerInfo in class io.confluent.security.authorizer.EmbeddedAuthorizer

start

public CompletableFuture<Void> start(org.apache.kafka.server.authorizer.internals.ConfluentAuthorizerServerInfo serverInfo,
                                     Runnable initTask)

Overrides:

start in class io.confluent.security.authorizer.EmbeddedAuthorizer