public abstract class BaseMultiTenantSaslSecretsStore extends Object implements org.apache.kafka.server.multitenant.MultiTenantSecretsStore
Modifier and Type | Class and Description |
---|---|
static class |
BaseMultiTenantSaslSecretsStore.State
The SecretsStore state.
|
Modifier and Type | Field and Description |
---|---|
static String |
METRICS_GROUP |
Constructor and Description |
---|
BaseMultiTenantSaslSecretsStore(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 BaseMultiTenantSaslSecretsStore |
getInstance(String brokerSessionUuid) |
Map<String,Long> |
getLastSequenceId() |
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 static final String METRICS_GROUP
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 BaseMultiTenantSaslSecretsStore getInstance(String brokerSessionUuid)