guyinyou

When I benchmarked rocketmq before, there was a need for back pressure. My approach was to maintain a semaphore to control the concurrent number of asynchronous sending, which achieved a...

> @guyinyou It seems that your approach is similar to my implementation, both use the semaphore to control the concurrent number of asynchronous sendings. Your idea about dynamic rateLimiter is...

now:  --- --- --- --- new: 

@fuyou001 @RongtongJin @zhouxinyu This is my current idea, let's see if there is a better solution

> It's seems like using @rety annotation in spring framework. I wonder in which case the channel will be not writable 🤔 The amount of data written to a single...

> From the point of view of stability, I suggest keeping the logic as it is, in benchmark case, consumer is not one instance, if we change , the code...

Is this topic of batchConsumeQueue type?

A msgId in batchConsumerQueue corresponds to an entire batch. If you want to maintain the same semantics as before, use an normal topic.

What version that consumer?

consumerManagerThreadPoolQueue also need fast failure, could you please add it ?