in signer/msk_auth_token_provider.go [346:369]
func logCallerIdentity(ctx context.Context, region string, awsCredentials aws.Credentials) {
cfg, err := config.LoadDefaultConfig(ctx,
config.WithRegion(region),
config.WithCredentialsProvider(credentials.StaticCredentialsProvider{
Value: awsCredentials,
}),
)
if err != nil {
log.Printf("failed to load AWS configuration: %v", err)
}
stsClient := sts.NewFromConfig(cfg)
callerIdentity, err := stsClient.GetCallerIdentity(ctx, &sts.GetCallerIdentityInput{})
if err != nil {
log.Printf("failed to get caller identity: %v", err)
}
log.Printf("Credentials Identity: {UserId: %s, Account: %s, Arn: %s}\n",
*callerIdentity.UserId,
*callerIdentity.Account,
*callerIdentity.Arn)
}