Skip to content

Commit

Permalink
Set credentials
Browse files Browse the repository at this point in the history
  • Loading branch information
atanasdinov committed Nov 3, 2022
1 parent 958a8f2 commit 0fd62a1
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion cmd/content-rw-elasticsearch/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -139,7 +139,10 @@ func main() {
}

arn := "arn:aws:kafka:eu-west-1:070529446553:cluster/upp-dev-msk-eu/fb827cd5-351e-4c16-9d4c-eb1face39ac1-2"
mskClient := msk.New(awsSession, aws.NewConfig().WithRegion("eu-west-1"))
mskClient := msk.New(awsSession,
aws.NewConfig().
WithCredentials(awsCreds).
WithRegion("eu-west-1"))
output, err := mskClient.DescribeClusterV2(&msk.DescribeClusterV2Input{
ClusterArn: &arn,
})
Expand Down

0 comments on commit 0fd62a1

Please sign in to comment.