let assume role session duration to be set as default 15 minutes

instaclustr · Sep 30, 2021 · d99025b · d99025b
1 parent f6cd799
commit d99025b
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/s3/src/main/java/com/instaclustr/kafka/connect/s3/TransferManagerProvider.java b/s3/src/main/java/com/instaclustr/kafka/connect/s3/TransferManagerProvider.java
@@ -42,7 +42,7 @@ public static AmazonS3ClientBuilder getS3ClientBuilderWithRegionAndCredentials(f
         AWSStaticCredentialsProvider awsStaticCredentialsProvider = new AWSStaticCredentialsProvider(new BasicAWSCredentials(accessKey, secret));
         AWSCredentialsProvider awsCredentialsProvider;
 
-        if (roleArn == null || StringUtils.isBlank(roleArn)) {
+        if (StringUtils.isBlank(roleArn)) {
             // when IAM user has direct access to the S3 bucket
             awsCredentialsProvider = awsStaticCredentialsProvider;
         } else {
@@ -58,7 +58,6 @@ public static AmazonS3ClientBuilder getS3ClientBuilderWithRegionAndCredentials(f
 
             awsCredentialsProvider = assumeRoleBuilder
                     .withStsClient(awsSecurityTokenService)
-                    .withRoleSessionDurationSeconds((int) TimeUnit.HOURS.toSeconds(1))
                     .build();
         }