in src/AWSMSKAuthTokenGenerator.cs [165:180]
public async Task<(string, long)> GenerateAuthTokenFromRoleAsync(RegionEndpoint region, string roleArn, string sessionName = "MSKSASLDefaultSession")
{
var assumeRoleReq = new AssumeRoleRequest()
{
RoleSessionName = sessionName,
RoleArn = roleArn
};
var assumeRoleResponse = await _stsClient.AssumeRoleAsync(assumeRoleReq, default);
var stsCredentials = assumeRoleResponse.Credentials;
return await GenerateAuthTokenFromCredentialsProvider(
() => new SessionAWSCredentials(stsCredentials.AccessKeyId, stsCredentials.SecretAccessKey,
stsCredentials.SessionToken), region);
}