opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-08-29 04:13:00 +08:00
Code Issues Packages Projects Releases Wiki Activity

Adjust the default value of ackMessageThreadPoolNums to 16 to prevent performance bottlenecks during high traffic. (#8337)

Browse Source
This commit is contained in:
rongtong
2024-07-02 17:08:54 +08:00
committed by GitHub
parent c6d3f2615b
commit 3aa5d1936f
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java
+1 -1
View File
@@ -70,7 +70,7 @@ public class BrokerConfig extends BrokerIdentity {
private int putMessageFutureThreadPoolNums = Math.min(PROCESSOR_NUMBER, 4);
private int pullMessageThreadPoolNums = 16 + PROCESSOR_NUMBER * 2;
private int litePullMessageThreadPoolNums = 16 + PROCESSOR_NUMBER * 2;
private int ackMessageThreadPoolNums = 3;
private int ackMessageThreadPoolNums = 16;
private int processReplyMessageThreadPoolNums = 16 + PROCESSOR_NUMBER * 2;
private int queryMessageThreadPoolNums = 8 + PROCESSOR_NUMBER;
store/src/main/java/org/apache/rocketmq/store/ConsumeQueue.java
+1 -1
View File
@@ -816,7 +816,7 @@ public class ConsumeQueue implements ConsumeQueueInterface, FileQueueLifeCycle {
long currentLogicOffset = mappedFile.getWrotePosition() + mappedFile.getFileFromOffset();
if (expectLogicOffset < currentLogicOffset) {
log.warn("Build consume queue repeatedly, expectLogicOffset: {} currentLogicOffset: {} Topic: {} QID: {} Diff: {}",
log.warn("Build consume queue repeatedly, expectLogicOffset: {} currentLogicOffset: {} Topic: {} QID: {} Diff: {}",
expectLogicOffset, currentLogicOffset, this.topic, this.queueId, expectLogicOffset - currentLogicOffset);
return true;
}