public class TopicBasedPlainSaslAuthenticator extends PlainSaslAuthenticator
AUTHENTICATION_FAILED_MSG, FAILED_AUTH_CACHE, log, mode, SUCCESSFUL_AUTH_CACHE, USER_RESOURCE_ID
Constructor and Description |
---|
TopicBasedPlainSaslAuthenticator(io.confluent.kafka.server.plugins.auth.BaseMultiTenantSaslSecretsStore secretsLoader) |
TopicBasedPlainSaslAuthenticator(Map<String,?> props) |
Modifier and Type | Method and Description |
---|---|
void |
initialize(List<AppConfigurationEntry> jaasContextEntries) |
protected io.confluent.kafka.server.plugins.auth.MultiTenantSaslSecrets |
loadSecrets() |
authenticate, clusterId, multiTenantPrincipal
public TopicBasedPlainSaslAuthenticator(io.confluent.kafka.server.plugins.auth.BaseMultiTenantSaslSecretsStore secretsLoader)
public void initialize(List<AppConfigurationEntry> jaasContextEntries)
protected io.confluent.kafka.server.plugins.auth.MultiTenantSaslSecrets loadSecrets()
loadSecrets
in class PlainSaslAuthenticator