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, org.apache.kafka.server.authorizer.ProviderGetter
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
    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
    Description
    AuthnzServerAuthorizer()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    configure(Map<String,?> configs)
     
    void
    configureServerInfo(org.apache.kafka.server.authorizer.internals.ConfluentAuthorizerServerInfo serverInfo)
     
    CompletableFuture<Void>
    start(org.apache.kafka.common.metrics.Metrics metrics)
     
    CompletableFuture<Void>
    start(org.apache.kafka.server.authorizer.internals.ConfluentAuthorizerServerInfo serverInfo, Runnable initTask)
     

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

    accessRuleProvider, accessRuleProviders, auditLogProvider, authorize, clearAuthorizerProvidersMap, close, getRbacGroupProvider, 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 Details

    • AuthnzServerAuthorizer

      public AuthnzServerAuthorizer()

  • Method Details

    • 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