in src/main/java/software/amazon/msk/auth/iam/internals/MSKCredentialProvider.java [181:191]
private Optional<STSAssumeRoleSessionCredentialsProvider> getStsRoleProvider() {
return Optional.ofNullable(optionsMap.get(AWS_ROLE_ARN_KEY)).map(p -> {
if (log.isDebugEnabled()) {
log.debug("Role ARN {}", p);
}
String sessionName = Optional.ofNullable((String) optionsMap.get(AWS_ROLE_SESSION_KEY))
.orElse("aws-msk-iam-auth");
String stsRegion = getStsRegion();
return createSTSRoleCredentialProvider((String) p, sessionName, stsRegion);
});
}