func newAWSMSKIAMSASL()

in kafka/common.go [360:376]

• 17 lines of code
• 3 McCabe index (conditional complexity)

func newAWSMSKIAMSASL() (sasl.Mechanism, error) {
	return aws.ManagedStreamingIAM(func(ctx context.Context) (aws.Auth, error) {
		awscfg, err := awsconfig.LoadDefaultConfig(ctx)
		if err != nil {
			return aws.Auth{}, fmt.Errorf("kafka: error loading AWS config: %w", err)
		}
		creds, err := awscfg.Credentials.Retrieve(ctx)
		if err != nil {
			return aws.Auth{}, err
		}
		return aws.Auth{
			AccessKey:    creds.AccessKeyID,
			SecretKey:    creds.SecretAccessKey,
			SessionToken: creds.SessionToken,
		}, nil
	}), nil
}