shengminw opened a new issue, #4599: URL: https://github.com/apache/rocketmq/issues/4599
In [#issue4554](https://github.com/apache/rocketmq/issues/4552), I suggest to add asySendBlockMode to implement BackPressure in producer. And I have implemented this relying on backpressure in NettyRemoting. ```java if (this.defaultMQProducer.isEnableBackpressureForAsyncMode()) { runnable.run(); } else { try { executor.submit(runnable); } catch (RejectedExecutionException e) { throw new MQClientException("executor rejected ", e); } } ``` To make a more accurate flow control mechanism, it is neccassary to expose backpressure monitor parameter to the users. So I consider to re-build a backpressure mechanism in async-sending message, not relying on backpressure in NettyRemoting. And at the same time, add message sizes as a backpressure monitor. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
