From c35524dae2d430d5ceb39b07e9124fac5d02648b Mon Sep 17 00:00:00 2001
From: Lari Hotari <lhotari@users.noreply.github.com>
Date: Tue, 10 Oct 2023 12:57:23 +0300
Subject: [PATCH] [fix][test] Fix flaky
 AdminApiMaxUnackedMessagesTest.testMaxUnackedMessagesPerConsumerPriority
 (#21335)

---
 .../pulsar/broker/admin/AdminApiMaxUnackedMessagesTest.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiMaxUnackedMessagesTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiMaxUnackedMessagesTest.java
index 4fb268fc9713f..9b95e41bb64e7 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiMaxUnackedMessagesTest.java
+++ b/pulsar-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;
             }