io.confluent.kafka.server.plugins.auth

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.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BaseMultiTenantSaslSecretsStore.State The SecretsStore state.

Field Summary

Fields

Modifier and Type	Field and Description
static String	METRICS_GROUP

Constructor Summary

Constructors

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

Method Summary

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)

Methods inherited from class java.lang.Object

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

Field Detail

METRICS_GROUP

public static final String METRICS_GROUP

See Also:

Constant Field Values

Constructor Detail

BaseMultiTenantSaslSecretsStore

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

Method Detail

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 Closeable

Specified by:

close in interface AutoCloseable

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)