diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java b/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
index 4aa605821f0..b54091e3ced 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
@@ -1626,7 +1626,6 @@ public Message request(final Message msg,
                 @Override
                 public void onSuccess(SendResult sendResult) {
                     requestResponseFuture.setSendRequestOk(true);
-                    requestResponseFuture.acquireCountDownLatch();
                 }
 
                 @Override
@@ -1684,7 +1683,6 @@ public Message request(final Message msg, final MessageQueueSelector selector, f
                 @Override
                 public void onSuccess(SendResult sendResult) {
                     requestResponseFuture.setSendRequestOk(true);
-                    requestResponseFuture.acquireCountDownLatch();
                 }
 
                 @Override
@@ -1742,7 +1740,6 @@ public Message request(final Message msg, final MessageQueue mq, final long time
                 @Override
                 public void onSuccess(SendResult sendResult) {
                     requestResponseFuture.setSendRequestOk(true);
-                    requestResponseFuture.acquireCountDownLatch();
                 }
 
                 @Override
diff --git a/client/src/main/java/org/apache/rocketmq/client/producer/RequestResponseFuture.java b/client/src/main/java/org/apache/rocketmq/client/producer/RequestResponseFuture.java
index 203f92907a4..e66c08fdc53 100644
--- a/client/src/main/java/org/apache/rocketmq/client/producer/RequestResponseFuture.java
+++ b/client/src/main/java/org/apache/rocketmq/client/producer/RequestResponseFuture.java
@@ -107,10 +107,6 @@ public void setSendRequestOk(boolean sendRequestOk) {
         this.sendRequestOk = sendRequestOk;
     }
 
-    public void acquireCountDownLatch() {
-        this.countDownLatch.countDown();
-    }
-
     public Message getRequestMsg() {
         return requestMsg;
     }