diff --git a/java/e2e/src/main/java/org/apache/rocketmq/util/VerifyUtils.java b/java/e2e/src/main/java/org/apache/rocketmq/util/VerifyUtils.java
index 045bb9a..f3c4ae8 100644
--- a/java/e2e/src/main/java/org/apache/rocketmq/util/VerifyUtils.java
+++ b/java/e2e/src/main/java/org/apache/rocketmq/util/VerifyUtils.java
@@ -540,7 +540,7 @@ public static void tryReceiveOnce(SimpleConsumer consumer, Boolean useExistTopic
                 cfs[i] = future;
             }
             try {
-                CompletableFuture.allOf(cfs).get(30, TimeUnit.SECONDS);
+                CompletableFuture.allOf(cfs).get(60, TimeUnit.SECONDS);
                 log.info("receive server response, cost={}ms", System.currentTimeMillis() - start);
             } catch (Exception e) {
                 throw new RuntimeException("receive response count not match");