public class FileBasedPlainSaslAuthenticator extends PlainSaslAuthenticator
Since we have to use JAAS, the JAAS config just points to the YAML config file.
AUTHENTICATION_FAILED_MSG, FAILED_AUTH_CACHE, log, mode, networkIdValidationMode, SUCCESSFUL_AUTH_CACHE, USER_RESOURCE_ID
Constructor and Description |
---|
FileBasedPlainSaslAuthenticator() |
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 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