diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/MessageChunkingSharedTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/MessageChunkingSharedTest.java index ff31409a24188..049aea35df0ce 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/MessageChunkingSharedTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/MessageChunkingSharedTest.java @@ -118,7 +118,7 @@ public void testMultiConsumers() throws Exception { producer.send(value); } - Awaitility.await().atMost(Duration.ofSeconds(3)) + Awaitility.await().atMost(Duration.ofSeconds(15)) .until(() -> receivedValues1.size() + receivedValues2.size() >= values.size()); assertEquals(receivedValues1.size() + receivedValues2.size(), values.size()); assertFalse(receivedValues1.isEmpty());