io.confluent.security.auth.provider.ldap

Class LdapStore

java.lang.Object

io.confluent.security.auth.provider.ldap.LdapStore

All Implemented Interfaces:

ExternalStore, org.apache.kafka.common.Configurable

public class LdapStore
extends Object
implements ExternalStore

Constructor Summary

Constructors

Constructor and Description
LdapStore(io.confluent.security.auth.metadata.AuthCache authCache, KafkaAuthWriter writer, org.apache.kafka.common.utils.Time time)

Method Summary

Modifier and Type	Method and Description
void	configure(Map<String,?> configs)
protected LdapGroupManager	createLdapGroupManager(ExternalStoreListener<io.confluent.security.auth.store.data.UserKey,io.confluent.security.auth.store.data.UserValue> listener)
boolean	failed() Returns true if the external store has failed and retries have timed out.
void	start(int generationId) Starts consuming metadata from the external store.
void	stop(Integer generationId) Stops consuming metadata from the external store if the provided generation id is null or equal to the current generation id of this store.

Methods inherited from class java.lang.Object

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

Constructor Detail

LdapStore

public LdapStore(io.confluent.security.auth.metadata.AuthCache authCache,
                 KafkaAuthWriter writer,
                 org.apache.kafka.common.utils.Time time)

Method Detail

configure

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

Specified by:

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

start

public void start(int generationId)

Description copied from interface: ExternalStore

Starts consuming metadata from the external store.

Specified by:

start in interface ExternalStore

Parameters:

generationId - The generation id of the writer

stop

public void stop(Integer generationId)

Description copied from interface: ExternalStore

Stops consuming metadata from the external store if the provided generation id is null or equal to the current generation id of this store.

Specified by:

stop in interface ExternalStore

Parameters:

generationId - The generation id to match or null to match any generation

failed

public boolean failed()

Description copied from interface: ExternalStore

Returns true if the external store has failed and retries have timed out.

Specified by:

failed in interface ExternalStore

createLdapGroupManager

protected LdapGroupManager createLdapGroupManager(ExternalStoreListener<io.confluent.security.auth.store.data.UserKey,io.confluent.security.auth.store.data.UserValue> listener)