feat(s3stream): add s3 operation timeout (#618)

Signed-off-by: Shichao Nie <niesc@automq.com>
AutoMQ · Nov 13, 2023 · d3545cd · d3545cd
1 parent 7541d02
commit d3545cd
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/s3stream/src/main/java/com/automq/stream/s3/operator/DefaultS3Operator.java b/s3stream/src/main/java/com/automq/stream/s3/operator/DefaultS3Operator.java
@@ -60,6 +60,7 @@
 
 import java.net.URI;
 import java.nio.charset.StandardCharsets;
+import java.time.Duration;
 import java.util.ArrayList;
 import java.util.Collections;
 import java.util.Date;
@@ -571,6 +572,8 @@ private static S3AsyncClient newS3Client(String endpoint, String region, boolean
                         AnonymousCredentialsProvider.create()
                 ).build()
         );
+        builder.overrideConfiguration(b -> b.apiCallTimeout(Duration.ofMinutes(1))
+                .apiCallAttemptTimeout(Duration.ofSeconds(30)));
         return builder.build();
     }