public class MultiTenantSaslSecretsStore extends Object implements org.apache.kafka.server.multitenant.MultiTenantSecretsStore
Modifier and Type | Class and Description |
---|---|
static class |
MultiTenantSaslSecretsStore.State
The SecretsStore state.
|
Constructor and Description |
---|
MultiTenantSaslSecretsStore(Map<String,Object> clientConfigs,
org.apache.kafka.common.metrics.Metrics metrics) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
configure(Map<String,?> config) |
static MultiTenantSaslSecretsStore |
getInstance(String brokerSessionUuid) |
MultiTenantSaslSecrets |
load()
The underlying secrets entries returned by this method may be concurrently modified on API key updates.
|
Map<org.apache.kafka.common.Endpoint,CompletableFuture<Void>> |
start(Collection<org.apache.kafka.common.Endpoint> endpoints) |
void |
updateSecrets(org.apache.kafka.clients.consumer.ConsumerRecord<String,String> record,
long currSeqId) |
public void configure(Map<String,?> config)
configure
in interface org.apache.kafka.common.Configurable
public Map<org.apache.kafka.common.Endpoint,CompletableFuture<Void>> start(Collection<org.apache.kafka.common.Endpoint> endpoints)
start
in interface org.apache.kafka.server.multitenant.MultiTenantSecretsStore
public void close()
close
in interface Closeable
close
in interface AutoCloseable
public MultiTenantSaslSecrets load()
public void updateSecrets(org.apache.kafka.clients.consumer.ConsumerRecord<String,String> record, long currSeqId)
public static MultiTenantSaslSecretsStore getInstance(String brokerSessionUuid)