diff --git a/cmd/content-rw-elasticsearch/main.go b/cmd/content-rw-elasticsearch/main.go
index 457de1a..a054062 100644
--- a/cmd/content-rw-elasticsearch/main.go
+++ b/cmd/content-rw-elasticsearch/main.go
@@ -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,
 			})