public class ConfluentServerAuthorizer
extends io.confluent.security.authorizer.EmbeddedAuthorizer
implements kafka.security.auth.AuthorizerWithKafkaStore
Constructor and Description |
---|
ConfluentServerAuthorizer() |
ConfluentServerAuthorizer(org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
void |
addAcls(scala.collection.immutable.Set<kafka.security.auth.Acl> acls,
kafka.security.auth.Resource resource) |
boolean |
authorize(kafka.network.RequestChannel.Session session,
kafka.security.auth.Operation operation,
kafka.security.auth.Resource resource) |
void |
close() |
void |
configure(java.util.Map<java.lang.String,?> configs) |
scala.collection.immutable.Map<kafka.security.auth.Resource,scala.collection.immutable.Set<kafka.security.auth.Acl>> |
getAcls() |
scala.collection.immutable.Map<kafka.security.auth.Resource,scala.collection.immutable.Set<kafka.security.auth.Acl>> |
getAcls(org.apache.kafka.common.security.auth.KafkaPrincipal principal) |
scala.collection.immutable.Set<kafka.security.auth.Acl> |
getAcls(kafka.security.auth.Resource resource) |
protected void |
initializeAndValidateLicense(java.util.Map<java.lang.String,?> configs) |
protected java.lang.String |
licensePropName() |
protected java.lang.String |
licenseStatusMetricGroup() |
boolean |
removeAcls(kafka.security.auth.Resource resource) |
boolean |
removeAcls(scala.collection.immutable.Set<kafka.security.auth.Acl> acls,
kafka.security.auth.Resource resource) |
accessRuleProvider, accessRuleProviders, authorize, configureProviders, groupProvider, isSuperUser, metadataProvider, onUpdate, ready, scope, start
public ConfluentServerAuthorizer()
public ConfluentServerAuthorizer(org.apache.kafka.common.utils.Time time)
public void configure(java.util.Map<java.lang.String,?> configs)
configure
in interface org.apache.kafka.common.Configurable
configure
in class io.confluent.security.authorizer.EmbeddedAuthorizer
public boolean authorize(kafka.network.RequestChannel.Session session, kafka.security.auth.Operation operation, kafka.security.auth.Resource resource)
public void addAcls(scala.collection.immutable.Set<kafka.security.auth.Acl> acls, kafka.security.auth.Resource resource)
public boolean removeAcls(scala.collection.immutable.Set<kafka.security.auth.Acl> acls, kafka.security.auth.Resource resource)
public boolean removeAcls(kafka.security.auth.Resource resource)
public scala.collection.immutable.Set<kafka.security.auth.Acl> getAcls(kafka.security.auth.Resource resource)
public scala.collection.immutable.Map<kafka.security.auth.Resource,scala.collection.immutable.Set<kafka.security.auth.Acl>> getAcls(org.apache.kafka.common.security.auth.KafkaPrincipal principal)
public scala.collection.immutable.Map<kafka.security.auth.Resource,scala.collection.immutable.Set<kafka.security.auth.Acl>> getAcls()
public void close()
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
close
in class io.confluent.security.authorizer.EmbeddedAuthorizer
protected final void initializeAndValidateLicense(java.util.Map<java.lang.String,?> configs)
initializeAndValidateLicense
in class io.confluent.security.authorizer.EmbeddedAuthorizer
protected java.lang.String licensePropName()
protected java.lang.String licenseStatusMetricGroup()