From 8d0fcbb6138fa93dbc99fde2f19e67f57537b491 Mon Sep 17 00:00:00 2001 From: "juntao.jjt" Date: Thu, 5 Jun 2025 16:41:40 +0800 Subject: [PATCH] optimize back pressure default value to 1024. --- .../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 11edcaa4410..a30443f8d1e 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