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