diff --git a/aws-kinesis-http-connector/version b/aws-kinesis-http-connector/version index 2048935..39fa176 100644 --- a/aws-kinesis-http-connector/version +++ b/aws-kinesis-http-connector/version @@ -1 +1 @@ -v0.15 +v0.16 diff --git a/aws-sqs-http-connector/version b/aws-sqs-http-connector/version index 39fa176..2b8bac3 100644 --- a/aws-sqs-http-connector/version +++ b/aws-sqs-http-connector/version @@ -1 +1 @@ -v0.16 +v0.17 diff --git a/common/util.go b/common/util.go index cc4fc0e..e2d3e34 100644 --- a/common/util.go +++ b/common/util.go @@ -133,7 +133,7 @@ func GetAwsConfig() (*aws.Config, error) { } if os.Getenv("AWS_ACCESS_KEY_ID") != "" && os.Getenv("AWS_SECRET_ACCESS_KEY") != "" { config.Credentials = credentials.NewStaticCredentials(os.Getenv("AWS_ACCESS_KEY_ID"), - os.Getenv("AWS_SECRET_ACCESS_KEY"), "") + os.Getenv("AWS_SECRET_ACCESS_KEY"), os.Getenv("AWS_SESSION_TOKEN")) return config, nil } if os.Getenv("AWS_CRED_PATH") != "" && os.Getenv("AWS_CRED_PROFILE") != "" {