in src/main/java/software/amazon/msk/auth/iam/internals/MSKCredentialProvider.java [375:392]
StsAssumeRoleCredentialsProvider createSTSRoleCredentialProvider(
String roleArn,
String sessionName, String stsRegion,
AwsCredentialsProvider credentials,
Boolean shouldUseFips) {
AssumeRoleRequest roleRequest = AssumeRoleRequest.builder()
.roleArn(roleArn)
.roleSessionName(sessionName)
.build();
StsClient stsClient = getStsClientBuilder(Region.of(stsRegion), shouldUseFips)
.credentialsProvider(credentials)
.build();
return StsAssumeRoleCredentialsProvider.builder()
.stsClient(stsClient)
.refreshRequest(roleRequest)
.asyncCredentialUpdateEnabled(true)
.build();
}