public class DefaultUserMetaDataStore extends Object implements org.apache.kafka.server.multitenant.UserMetadataStore
Modifier and Type | Class and Description |
---|---|
static class |
DefaultUserMetaDataStore.State |
Modifier and Type | Field and Description |
---|---|
protected static Map<String,DefaultUserMetaDataStore> |
INSTANCES |
protected List<String> |
multitenantListenerNames |
protected String |
sessionUuid |
protected String |
topicName |
static String |
USER_METADATA_COUNT |
static String |
USER_METADATA_EVENT_FAILURE_RATE |
static String |
USER_METADATA_EVENT_RATE |
static String |
USER_METADATA_TOPIC_LOAD_TIME |
Constructor and 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) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
configure(Map<String,?> configs) |
static DefaultUserMetaDataStore |
getInstance(String brokerSessionUuid) |
org.apache.kafka.common.metrics.Metrics |
metrics() |
int |
numOfMapping() |
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) |
Optional<String> |
userIdToUserResourceId(String userId) |
Optional<String> |
userResourceIdToUserId(String userResourceId) |
public static final String USER_METADATA_EVENT_RATE
public static final String USER_METADATA_EVENT_FAILURE_RATE
public static final String USER_METADATA_COUNT
public static final String USER_METADATA_TOPIC_LOAD_TIME
protected static final Map<String,DefaultUserMetaDataStore> INSTANCES
protected String sessionUuid
protected String topicName
public DefaultUserMetaDataStore(Map<String,?> interBrokerClientConfig, org.apache.kafka.common.metrics.Metrics metrics)
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.UserMetadataStore
public void close()
close
in interface Closeable
close
in interface AutoCloseable
IOException
public void configure(Map<String,?> configs)
configure
in interface org.apache.kafka.common.Configurable
public static DefaultUserMetaDataStore getInstance(String brokerSessionUuid)
public int numOfMapping()
public org.apache.kafka.common.metrics.Metrics metrics()