public class MultiTenantAuthorizer extends ConfluentServerAuthorizer
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
MAX_ACLS_PER_TENANT_PROP |
Constructor and Description |
---|
MultiTenantAuthorizer() |
Modifier and Type | Method and Description |
---|---|
void |
addAcls(scala.collection.immutable.Set<kafka.security.auth.Acl> acls,
kafka.security.auth.Resource resource) |
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) |
boolean |
removeAcls(kafka.security.auth.Resource resource) |
boolean |
removeAcls(scala.collection.immutable.Set<kafka.security.auth.Acl> aclsTobeRemoved,
kafka.security.auth.Resource resource) |
authorize, close, initializeAndValidateLicense, licensePropName, licenseStatusMetricGroup
accessRuleProvider, accessRuleProviders, authorize, configureProviders, groupProvider, isSuperUser, metadataProvider, onUpdate, ready, scope, start
public static final java.lang.String MAX_ACLS_PER_TENANT_PROP
public void configure(java.util.Map<java.lang.String,?> configs)
configure
in interface org.apache.kafka.common.Configurable
configure
in class ConfluentServerAuthorizer
public void addAcls(scala.collection.immutable.Set<kafka.security.auth.Acl> acls, kafka.security.auth.Resource resource)
addAcls
in class ConfluentServerAuthorizer
public boolean removeAcls(scala.collection.immutable.Set<kafka.security.auth.Acl> aclsTobeRemoved, kafka.security.auth.Resource resource)
removeAcls
in class ConfluentServerAuthorizer
public boolean removeAcls(kafka.security.auth.Resource resource)
removeAcls
in class ConfluentServerAuthorizer
public scala.collection.immutable.Set<kafka.security.auth.Acl> getAcls(kafka.security.auth.Resource resource)
getAcls
in class ConfluentServerAuthorizer
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)
getAcls
in class ConfluentServerAuthorizer
public scala.collection.immutable.Map<kafka.security.auth.Resource,scala.collection.immutable.Set<kafka.security.auth.Acl>> getAcls()
getAcls
in class ConfluentServerAuthorizer