guyinyou
guyinyou
If diskspacewarninglevelratio is less than diskspaceclenforciblyratio, it will never go to the logic that `if(minPhysicRatio > diskspaceclenforciblyratio)`
@yuz10 There is no lamda expression in jdk1.6. For compatibility with it, replace computeIfAbsent with putIfAbsent.
> Whether there will be a performance improvement report in the future when using this feature I plan to do some benchmarks after Chinese New Year, now here I wish...
Since the new broker processes the messageBatch as a single message, it should not support the case of multiple topics in one messageBatch @duhenglucky
I also think that it is a very good choice to put configuration-related variables in ClientConfig. At the same time, it is necessary to consider how to deal with the...
org/apache/rocketmq/namesrv/routeinfo/BatchUnRegisterService.java:63 `while (!this.isStopped()) {` use poll can make thread graceful stop. maybe this is the original intention
niubility!
The back pressure mechanism is a very useful function, but at present, when the traffic of rocketmq is close to the bottleneck, the traffic will drop sharply due to "buzy"....
> The effect is still very obvious, well done.