public class OAuthBearerServerLoginCallbackHandler
extends java.lang.Object
implements org.apache.kafka.common.security.auth.AuthenticateCallbackHandler
CallbackHandler
for the OAuthLoginModule of a Kafka Broker.
It works as a work-around for KAFKA-7462 and validates that a valid PEM public key is given.
org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule Required publicKeyPath="/tmp/key.pem"
This class should be explicitly set via the
listener.name.XXX.YYY.sasl.login.callback.handler.class
configuration property
Constructor and Description |
---|
OAuthBearerServerLoginCallbackHandler() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
configure(java.util.Map<java.lang.String,?> configs,
java.lang.String saslMechanism,
java.util.List<javax.security.auth.login.AppConfigurationEntry> jaasConfigEntries) |
void |
handle(javax.security.auth.callback.Callback[] callbacks) |
public OAuthBearerServerLoginCallbackHandler()
public void configure(java.util.Map<java.lang.String,?> configs, java.lang.String saslMechanism, java.util.List<javax.security.auth.login.AppConfigurationEntry> jaasConfigEntries)
configure
in interface org.apache.kafka.common.security.auth.AuthenticateCallbackHandler
public void handle(javax.security.auth.callback.Callback[] callbacks) throws javax.security.auth.callback.UnsupportedCallbackException
handle
in interface javax.security.auth.callback.CallbackHandler
javax.security.auth.callback.UnsupportedCallbackException
public void close()
close
in interface org.apache.kafka.common.security.auth.AuthenticateCallbackHandler