Skip to content

Commit

Permalink
Merge branch 'main' into fix/duplicate-field-in-postgresql
Browse files Browse the repository at this point in the history
  • Loading branch information
Eileen-Yu authored Sep 9, 2024
2 parents 27af5a3 + 4c53816 commit bf9adc8
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions bindings/aws/kinesis/kinesis.go
Original file line number Diff line number Diff line change
Expand Up @@ -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"
Expand Down Expand Up @@ -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
}

Expand Down

0 comments on commit bf9adc8

Please sign in to comment.