diff --git a/client/src/test/java/org/apache/rocketmq/client/producer/DefaultMQProducerTest.java b/client/src/test/java/org/apache/rocketmq/client/producer/DefaultMQProducerTest.java index 35f65e36c2d7c21d2d0c71534d64812b996c137d..7fb2621c4a03f36031a568a777471cb906cabfee 100644 --- a/client/src/test/java/org/apache/rocketmq/client/producer/DefaultMQProducerTest.java +++ b/client/src/test/java/org/apache/rocketmq/client/producer/DefaultMQProducerTest.java @@ -201,7 +201,7 @@ public class DefaultMQProducerTest { public void onException(Throwable e) { } }); - countDownLatch.await(3000L, TimeUnit.MILLISECONDS); + countDownLatch.await(20000L, TimeUnit.MILLISECONDS); assertThat(cc.get()).isEqualTo(1); }