fix(s3stream): catch storage callback exception

Signed-off-by: Robin Han <[email protected]>
AutoMQ · Dec 15, 2023 · 12a779b · 12a779b
1 parent 848cdde
commit 12a779b
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/s3stream/src/main/java/com/automq/stream/s3/S3Storage.java b/s3stream/src/main/java/com/automq/stream/s3/S3Storage.java
@@ -69,6 +69,8 @@
 import java.util.stream.Collectors;
 import java.util.stream.IntStream;
 
+import static com.automq.stream.utils.FutureUtil.suppress;
+
 
 public class S3Storage implements Storage {
     private static final Logger LOGGER = LoggerFactory.getLogger(S3Storage.class);
@@ -426,6 +428,10 @@ private void handleAppendRequest(WalWriteRequest request) {
     }
 
     private void handleAppendCallback(WalWriteRequest request) {
+        suppress(() -> handleAppendCallback0(request), LOGGER);
+    }
+
+    private void handleAppendCallback0(WalWriteRequest request) {
         TimerUtil timer = new TimerUtil();
         List<WalWriteRequest> waitingAckRequests;
         Lock lock = getStreamCallbackLock(request.record.getStreamId());