make the v2 creds provider be the default

Signed-off-by: swatimodi-scout <swati.modi@scoutmotors.com>

Author: swatimodi-scout

bindings/aws/kinesis/kinesis.go

@@ -53,6 +53,9 @@ type AWSKinesis struct {
 	closed          atomic.Bool
 	closeCh         chan struct{}
 	wg              sync.WaitGroup
+	// applicationName is required for KCL (Kinesis Client Library) worker configuration
+	// in shared throughput mode. It identifies the consumer application and is used
+	// for DynamoDB table naming and checkpointing.
 	applicationName string
 }
 

common/authentication/aws/client.go

@@ -19,6 +19,7 @@ import (
 	"sync"
 
 	"github.com/aws/aws-sdk-go-v2/aws"
+	awsv2config "github.com/aws/aws-sdk-go-v2/config"
 	v2creds "github.com/aws/aws-sdk-go-v2/credentials"
 	"github.com/aws/aws-sdk-go/aws/credentials"
 	"github.com/aws/aws-sdk-go/aws/session"
@@ -199,10 +200,19 @@ func (c *KinesisClients) WorkerCfg(ctx context.Context, stream, region, mode, ap
 	const sharedMode = "shared"
 	if c.Kinesis != nil {
 		if mode == sharedMode {
-			v1Creds, err := c.Credentials.Get()
-			if err != nil {
+			// Try v2 default config first (standard approach for v2 components)
+			v2Config, err := awsv2config.LoadDefaultConfig(ctx, awsv2config.WithRegion(region))
+			if err == nil {
+				kclConfig := config.NewKinesisClientLibConfigWithCredential(applicationName, stream, region, "", v2Config.Credentials)
+				return kclConfig
+			}
+			// Fallback to v1 credentials if v2 fails
+			v1Creds, v1Err := c.Credentials.Get()
+			if v1Err != nil {
+				// Both v2 and v1 failed, return nil
 				return nil
 			}
+			// Convert v1 credentials to v2 format
 			v2Creds := v2creds.NewStaticCredentialsProvider(v1Creds.AccessKeyID, v1Creds.SecretAccessKey, v1Creds.SessionToken)
 			kclConfig := config.NewKinesisClientLibConfigWithCredential(applicationName, stream, region, "", v2Creds)
 			return kclConfig