public class LdapStore extends Object implements ExternalStore
Constructor and Description |
---|
LdapStore(io.confluent.security.auth.metadata.AuthCache authCache,
KafkaAuthWriter writer,
org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
void |
configure(Map<String,?> configs) |
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.
|
public LdapStore(io.confluent.security.auth.metadata.AuthCache authCache, KafkaAuthWriter writer, org.apache.kafka.common.utils.Time time)
public void configure(Map<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(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