public class LdapGroupProvider
extends java.lang.Object
implements io.confluent.security.authorizer.provider.GroupProvider
Constructor and Description |
---|
LdapGroupProvider() |
LdapGroupProvider(org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
configure(java.util.Map<java.lang.String,?> configs) |
java.util.Set<org.apache.kafka.common.security.auth.KafkaPrincipal> |
groups(org.apache.kafka.common.security.auth.KafkaPrincipal sessionPrincipal) |
LdapGroupManager |
ldapGroupManager() |
boolean |
providerConfigured(java.util.Map<java.lang.String,?> configs) |
java.lang.String |
providerName() |
boolean |
usesMetadataFromThisKafkaCluster() |
public LdapGroupProvider()
public LdapGroupProvider(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
public java.lang.String providerName()
providerName
in interface io.confluent.security.authorizer.provider.Provider
public boolean providerConfigured(java.util.Map<java.lang.String,?> configs)
providerConfigured
in interface io.confluent.security.authorizer.provider.GroupProvider
public java.util.Set<org.apache.kafka.common.security.auth.KafkaPrincipal> groups(org.apache.kafka.common.security.auth.KafkaPrincipal sessionPrincipal)
groups
in interface io.confluent.security.authorizer.provider.GroupProvider
public boolean usesMetadataFromThisKafkaCluster()
usesMetadataFromThisKafkaCluster
in interface io.confluent.security.authorizer.provider.Provider
public void close()
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
public LdapGroupManager ldapGroupManager()