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 7fb2621c4a03f36031a568a777471cb906cabfee..8e73ba5eae4aece7769645c2a11975168ce731c0 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(20000L, TimeUnit.MILLISECONDS);
+        countDownLatch.await(8000L, TimeUnit.MILLISECONDS);
         assertThat(cc.get()).isEqualTo(1);
     }