public class LdapStore extends java.lang.Object implements ExternalStore
Constructor and Description |
---|
LdapStore(AuthCache authCache,
KafkaAuthWriter writer,
org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
void |
configure(java.util.Map<java.lang.String,?> configs) |
protected LdapGroupManager |
createLdapGroupManager(ExternalStoreListener<UserKey,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(java.lang.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.
|
public LdapStore(AuthCache authCache, KafkaAuthWriter writer, 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 void start(int generationId)
ExternalStore
start
in interface ExternalStore
generationId
- The generation id of the writerpublic void stop(java.lang.Integer generationId)
ExternalStore
stop
in interface ExternalStore
generationId
- The generation id to match or null to match any generationpublic boolean failed()
ExternalStore
failed
in interface ExternalStore
protected LdapGroupManager createLdapGroupManager(ExternalStoreListener<UserKey,UserValue> listener)