From 6614d6a4485686ccc2de4dc47bf376bfa87d69ee Mon Sep 17 00:00:00 2001 From: arr Date: Tue, 27 Aug 2024 17:55:11 -0600 Subject: [PATCH] reuse existing aws client credentials; Signed-off-by: arr --- bindings/aws/kinesis/kinesis.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/bindings/aws/kinesis/kinesis.go b/bindings/aws/kinesis/kinesis.go index 8f403e3a2f..94bf590bb4 100644 --- a/bindings/aws/kinesis/kinesis.go +++ b/bindings/aws/kinesis/kinesis.go @@ -23,7 +23,6 @@ import ( "time" "github.com/aws/aws-sdk-go/aws" - "github.com/aws/aws-sdk-go/aws/credentials" "github.com/aws/aws-sdk-go/aws/request" "github.com/aws/aws-sdk-go/service/kinesis" "github.com/cenkalti/backoff/v4" @@ -129,7 +128,7 @@ func (a *AWSKinesis) Init(ctx context.Context, metadata bindings.Metadata) error if m.KinesisConsumerMode == SharedThroughput { kclConfig := config.NewKinesisClientLibConfigWithCredential(m.ConsumerName, m.StreamName, m.Region, m.ConsumerName, - credentials.NewStaticCredentials(m.AccessKey, m.SecretKey, "")) + client.Config.Credentials) a.workerConfig = kclConfig }