public class AuthnzMultiTenantSaslSecretsStore
extends io.confluent.kafka.server.plugins.auth.BaseMultiTenantSaslSecretsStore
Constructor and Description |
---|
AuthnzMultiTenantSaslSecretsStore(Map<String,Object> clientConfigs,
org.apache.kafka.common.metrics.Metrics metrics) |
Modifier and Type | Method and Description |
---|---|
protected void |
createSensors(Map<String,io.confluent.kafka.server.plugins.auth.MultiTenantSaslConfigEntry> entries) |
protected void |
deleteCredential(String deletedKey) |
protected Map<String,Object> |
getConsumerConfig(Map<String,?> config) |
protected String |
getSessionUuid(Map<String,?> config) |
protected void |
read(org.apache.kafka.clients.consumer.ConsumerRecord<String,String> record) |
protected String getSessionUuid(Map<String,?> config)
getSessionUuid
in class io.confluent.kafka.server.plugins.auth.BaseMultiTenantSaslSecretsStore
protected void deleteCredential(String deletedKey)
deleteCredential
in class io.confluent.kafka.server.plugins.auth.BaseMultiTenantSaslSecretsStore
protected Map<String,Object> getConsumerConfig(Map<String,?> config)
getConsumerConfig
in class io.confluent.kafka.server.plugins.auth.BaseMultiTenantSaslSecretsStore
protected void read(org.apache.kafka.clients.consumer.ConsumerRecord<String,String> record)
read
in class io.confluent.kafka.server.plugins.auth.BaseMultiTenantSaslSecretsStore