public class TokenCertificateLoginCallbackHandler extends AbstractTokenLoginCallbackHandler
CallbackHandler for the OAuthBearerLoginModule.
This supports Kafka clients to exchange certificate for MDS issued token
This class handles the certificate credential approach and can be configured as such.
org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule Required
metadataServerUrls="https://mds:8080"
This class should be explicitly set via the
sasl.login.callback.handler.class configuration property| Constructor and Description |
|---|
TokenCertificateLoginCallbackHandler() |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
void |
configure(Map<String,?> configs) |
void |
validateHaveCredentials(Map<String,String> moduleOptions,
Map<String,?> configs) |
configure, handlepublic TokenCertificateLoginCallbackHandler()
public void configure(Map<String,?> configs)
configure in class AbstractTokenLoginCallbackHandlerpublic void close()
close in interface org.apache.kafka.common.security.auth.AuthenticateCallbackHandlerclose in class AbstractTokenLoginCallbackHandlerpublic void validateHaveCredentials(Map<String,String> moduleOptions, Map<String,?> configs) throws org.apache.kafka.common.config.ConfigException
validateHaveCredentials in class AbstractTokenLoginCallbackHandlerorg.apache.kafka.common.config.ConfigException