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