Class DefaultUserMetaDataStore

java.lang.Object

io.confluent.kafka.server.plugins.auth.DefaultUserMetaDataStore

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.kafka.common.Configurable, org.apache.kafka.server.multitenant.UserMetadataStore

public class DefaultUserMetaDataStore
extends Object
implements org.apache.kafka.server.multitenant.UserMetadataStore

This class loads user metadata from the topic _confluent-user_metadata. Note: Topic name can be changed using configs.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	DefaultUserMetaDataStore.State

Field Summary

Fields

Modifier and Type	Field	Description
static final String	USER_METADATA_COUNT
static final String	USER_METADATA_EVENT_FAILURE_RATE
static final String	USER_METADATA_EVENT_RATE
static final String	USER_METADATA_TOPIC_LOAD_TIME

Constructor Summary

Constructors

Constructor	Description
DefaultUserMetaDataStore(Map<String,?> interBrokerClientConfig, org.apache.kafka.common.metrics.Metrics metrics)
DefaultUserMetaDataStore(Map<String,?> interBrokerClientConfigs, org.apache.kafka.common.metrics.Metrics metrics, org.apache.kafka.common.utils.Time time)

Method Summary

Modifier and Type	Method	Description
void	close()
void	configure(Map<String,?> configs)
static DefaultUserMetaDataStore	getInstance(String brokerSessionUuid)
org.apache.kafka.common.metrics.Metrics	metrics()
int	numOfMapping()
Map<org.apache.kafka.common.Endpoint, CompletableFuture<Void>>	start(org.apache.kafka.server.authorizer.AuthorizerServerInfo serverInfo)
Optional<String>	userIdToUserResourceId(String userId)
Optional<String>	userResourceIdToUserId(String userResourceId)

Methods inherited from class java.lang.Object

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

Field Details

USER_METADATA_EVENT_RATE

public static final String USER_METADATA_EVENT_RATE

See Also:

• Constant Field Values

USER_METADATA_EVENT_FAILURE_RATE

public static final String USER_METADATA_EVENT_FAILURE_RATE

See Also:

• Constant Field Values

USER_METADATA_COUNT

public static final String USER_METADATA_COUNT

See Also:

• Constant Field Values

USER_METADATA_TOPIC_LOAD_TIME

public static final String USER_METADATA_TOPIC_LOAD_TIME

See Also:

• Constant Field Values

Constructor Details

DefaultUserMetaDataStore

public DefaultUserMetaDataStore(Map<String,?> interBrokerClientConfig,
 org.apache.kafka.common.metrics.Metrics metrics)

DefaultUserMetaDataStore

public DefaultUserMetaDataStore(Map<String,?> interBrokerClientConfigs,
 org.apache.kafka.common.metrics.Metrics metrics,
 org.apache.kafka.common.utils.Time time)

Method Details

start

public Map<org.apache.kafka.common.Endpoint, CompletableFuture<Void>> start(org.apache.kafka.server.authorizer.AuthorizerServerInfo serverInfo)

Specified by:

start in interface org.apache.kafka.server.multitenant.UserMetadataStore

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

configure

public void configure(Map<String,?> configs)

Specified by:

configure in interface org.apache.kafka.common.Configurable

getInstance

public static DefaultUserMetaDataStore getInstance(String brokerSessionUuid)

userIdToUserResourceId

public Optional<String> userIdToUserResourceId(String userId)

userResourceIdToUserId

public Optional<String> userResourceIdToUserId(String userResourceId)

numOfMapping

public int numOfMapping()

metrics

public org.apache.kafka.common.metrics.Metrics metrics()