Package software.amazon.msk.auth.iam

Class IAMOAuthBearerLoginCallbackHandler

java.lang.Object

software.amazon.msk.auth.iam.IAMOAuthBearerLoginCallbackHandler

All Implemented Interfaces:

CallbackHandler, org.apache.kafka.common.security.auth.AuthenticateCallbackHandler

public class IAMOAuthBearerLoginCallbackHandler
extends Object
implements org.apache.kafka.common.security.auth.AuthenticateCallbackHandler

This login callback handler is used to extract base64 encoded signed url as an auth token. The credentials are based on JaasConfig options passed to OAuthBearerLoginModule. If config options are provided the MSKCredentialProvider is used. If no config options are provided it uses the DefaultAWSCredentialsProviderChain.

Constructor Summary

Constructors

Constructor	Description
IAMOAuthBearerLoginCallbackHandler()

Method Summary

Modifier and Type	Method	Description
void	close()
void	configure(Map<String,?> configs, @NonNull String saslMechanism, @NonNull List<AppConfigurationEntry> jaasConfigEntries)
boolean	configured()	Return true if this instance has been configured, otherwise false.
void	handle(@NonNull Callback[] callbacks)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

IAMOAuthBearerLoginCallbackHandler

public IAMOAuthBearerLoginCallbackHandler()

Method Details

configured

public boolean configured()

Return true if this instance has been configured, otherwise false.

configure

public void configure(Map<String,?> configs,
 @NonNull
 @NonNull String saslMechanism,
 @NonNull
 @NonNull List<AppConfigurationEntry> jaasConfigEntries)

Specified by:

configure in interface org.apache.kafka.common.security.auth.AuthenticateCallbackHandler

close

public void close()

Specified by:

close in interface org.apache.kafka.common.security.auth.AuthenticateCallbackHandler

handle

public void handle(@NonNull
 @NonNull Callback[] callbacks)
            throws IOException,
UnsupportedCallbackException

Specified by:

handle in interface CallbackHandler

Throws:

IOException

UnsupportedCallbackException