Package software.amazon.msk.auth.iam

Class IAMClientCallbackHandler

java.lang.Object

software.amazon.msk.auth.iam.IAMClientCallbackHandler

All Implemented Interfaces:

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

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

This client callback handler is used to extract AWSCredentials. The credentials are based on JaasConfig options passed to IAMLoginModule. If config options are provided the MSKCredentialProvider is used. If no config options are provided it uses the DefaultAWSCredentialsProviderChain.

Constructor Summary

Constructors

Constructor	Description
IAMClientCallbackHandler()

Method Summary

Modifier and Type	Method	Description
void	close()
void	configure(Map<String,?> configs, @NonNull String saslMechanism, @NonNull List<AppConfigurationEntry> jaasConfigEntries)
protected static String	debugClassString(Class<?> clazz)
void	handle(@NonNull Callback[] callbacks)
protected void	handleCallback(AWSCredentialsCallback callback)

Methods inherited from class java.lang.Object

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

Constructor Details

IAMClientCallbackHandler

public IAMClientCallbackHandler()

Method Details

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

debugClassString

protected static String debugClassString(Class<?> clazz)

handleCallback

protected void handleCallback(AWSCredentialsCallback callback)
                       throws IOException

Throws:

IOException