Package 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
    Description
    LdapStore(io.confluent.security.auth.metadata.AuthCache authCache, KafkaAuthWriter writer, org.apache.kafka.common.utils.Time time)
     

  • Method Summary

    Modifier and Type
    Method
    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.

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • LdapStore

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

  • Method Details

    • 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