We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 4f9d292 commit cfddd12Copy full SHA for cfddd12
1 file changed
client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java
@@ -170,9 +170,9 @@ public class DefaultMQProducer extends ClientConfig implements MQProducer {
170
171
/**
172
* on BackpressureForAsyncMode, limit maximum number of on-going sending async messages
173
- * default is 10000
+ * default is 1024
174
*/
175
- private int backPressureForAsyncSendNum = 10000;
+ private int backPressureForAsyncSendNum = 1024;
176
177
178
* on BackpressureForAsyncMode, limit maximum message size of on-going sending async messages
0 commit comments