[fix][test] Fix flaky AdminApiMaxUnackedMessagesTest.testMaxUnackedMe…

…ssagesPerConsumerPriority (apache#21335)
ascentstream · Oct 10, 2023 · c35524d · c35524d
1 parent 9449ae4
commit c35524d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...r-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiMaxUnackedMessagesTest.java b/...r-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiMaxUnackedMessagesTest.java
@@ -197,7 +197,7 @@ public void testMaxUnackedMessagesPerConsumerPriority() throws Exception {
     private List<Message> consumeMsg(Consumer<?> consumer, int msgNum) throws Exception {
         List<Message> list = new ArrayList<>();
         for (int i = 0; i <msgNum; i++) {
-            Message message = consumer.receive(500, TimeUnit.MILLISECONDS);
+            Message message = consumer.receive(1500, TimeUnit.MILLISECONDS);
             if (message == null) {
                 break;
             }