fix: improve keep alive of simple consumer recevive

Signed-off-by: wangxye <[email protected]>
AutoMQ · Nov 8, 2023 · a05171f · a05171f
1 parent bfd70df
commit a05171f
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -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");