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 |
---|---|
protected Map<String,?> |
baseClientProperties |
protected static Map<String,BaseMultiTenantSaslSecretsStore> |
INSTANCES |
protected static org.slf4j.Logger |
LOG |
protected org.apache.kafka.common.metrics.Metrics |
metrics |
static String |
METRICS_GROUP |
protected List<String> |
multitenantListenerNames |
protected org.apache.kafka.connect.util.KafkaBasedLog<String,String> |
secretsLog |
protected String |
sessionUuid |
protected Long |
topicLoadTimeoutMs |
protected String |
topicName |
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) |
protected abstract void |
createSensors(Map<String,MultiTenantSaslConfigEntry> entries) |
protected abstract void |
deleteCredential(String deletedKey) |
protected abstract Map<String,Object> |
getConsumerConfig(Map<String,?> config) |
static BaseMultiTenantSaslSecretsStore |
getInstance(String brokerSessionUuid) |
Map<String,Long> |
getLastSequenceId() |
protected abstract String |
getSessionUuid(Map<String,?> config) |
MultiTenantSaslSecrets |
load()
The underlying secrets entries returned by this method may be concurrently modified on API key updates.
|
protected void |
read(org.apache.kafka.clients.consumer.ConsumerRecord<String,String> record) |
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) |
protected static final Map<String,BaseMultiTenantSaslSecretsStore> INSTANCES
protected static final org.slf4j.Logger LOG
public static final String METRICS_GROUP
protected String sessionUuid
protected String topicName
protected Long topicLoadTimeoutMs
protected final org.apache.kafka.common.metrics.Metrics metrics
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()
protected abstract void createSensors(Map<String,MultiTenantSaslConfigEntry> entries)
public void updateSecrets(org.apache.kafka.clients.consumer.ConsumerRecord<String,String> record, long currSeqId)
protected abstract void deleteCredential(String deletedKey)
public static BaseMultiTenantSaslSecretsStore getInstance(String brokerSessionUuid)