in src/main/java/software/amazon/msk/auth/iam/internals/EnhancedProfileCredentialsProvider.java [33:42]
public AWSCredentials getCredentials() {
software.amazon.awssdk.auth.credentials.AwsCredentials credentialsV2 = delegate.resolveCredentials();
if (credentialsV2 instanceof AwsSessionCredentials) {
AwsSessionCredentials sessionCredentialsV2 = (AwsSessionCredentials) credentialsV2;
return new BasicSessionCredentials(sessionCredentialsV2.accessKeyId(),
sessionCredentialsV2.secretAccessKey(), sessionCredentialsV2.sessionToken());
}
return new BasicAWSCredentials(credentialsV2.accessKeyId(), credentialsV2.secretAccessKey());
}