This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new cfddd12c2c [ISSUE #9451]Optimize back pressure default value to 1024. 
(#9452)
cfddd12c2c is described below

commit cfddd12c2c03b67ed78c8b27f4856021c5f1e003
Author: Ji Juntao <[email protected]>
AuthorDate: Thu Jun 5 19:04:34 2025 +0800

    [ISSUE #9451]Optimize back pressure default value to 1024. (#9452)
---
 .../java/org/apache/rocketmq/client/producer/DefaultMQProducer.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java
 
b/client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java
index 11edcaa441..a30443f8d1 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java
@@ -170,9 +170,9 @@ public class DefaultMQProducer extends ClientConfig 
implements MQProducer {
 
     /**
      * on BackpressureForAsyncMode, limit maximum number of on-going sending 
async messages
-     * default is 10000
+     * default is 1024
      */
-    private int backPressureForAsyncSendNum = 10000;
+    private int backPressureForAsyncSendNum = 1024;
 
     /**
      * on BackpressureForAsyncMode, limit maximum message size of on-going 
sending async messages

Reply via email to