Class BaseMultiTenantSaslSecretsStore

java.lang.Object
io.confluent.kafka.server.plugins.auth.BaseMultiTenantSaslSecretsStore
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.kafka.common.Configurable, org.apache.kafka.server.multitenant.MultiTenantSecretsStore
public abstract class BaseMultiTenantSaslSecretsStore extends Object implements org.apache.kafka.server.multitenant.MultiTenantSecretsStore
This class loads SASL secrets from the topic _confluent-apikey.

  • Field Details

  • Constructor Details

    • BaseMultiTenantSaslSecretsStore

      public BaseMultiTenantSaslSecretsStore(Map<String,Object> clientConfigs, org.apache.kafka.common.metrics.Metrics metrics)

  • Method Details

    • configure

      public void configure(Map<String,?> config)
      Specified by:
      configure in interface org.apache.kafka.common.Configurable

    • start

      public Map<org.apache.kafka.common.Endpoint, CompletableFuture<Void>> start(Collection<org.apache.kafka.common.Endpoint> endpoints)
      Specified by:
      start in interface org.apache.kafka.server.multitenant.MultiTenantSecretsStore

    • getLastSequenceId

      public Map<String,Long> getLastSequenceId()

    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable

    • load

      public MultiTenantSaslSecrets load()
      The underlying secrets entries returned by this method may be concurrently modified on API key updates.

    • updateSecrets

      public void updateSecrets(org.apache.kafka.clients.consumer.ConsumerRecord<String,String> record, long currSeqId)

    • getInstance

      public static BaseMultiTenantSaslSecretsStore getInstance(String brokerSessionUuid)