This is an automated email from the ASF dual-hosted git repository.
zhouxzhan pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new 3ac5c73cd1 [ISSUE #8281] Optimize pop log level (#8282)
3ac5c73cd1 is described below
commit 3ac5c73cd1fbd715525bff6e6aa9f4bfe768ca30
Author: Zhouxiang Zhan <[email protected]>
AuthorDate: Thu Jun 13 14:48:12 2024 +0800
[ISSUE #8281] Optimize pop log level (#8282)
* change pop log level to debug when all the revive messages are handled
---
.../java/org/apache/rocketmq/broker/processor/PopReviveService.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/broker/src/main/java/org/apache/rocketmq/broker/processor/PopReviveService.java
b/broker/src/main/java/org/apache/rocketmq/broker/processor/PopReviveService.java
index 4fab3d500b..e3ba492f28 100644
---
a/broker/src/main/java/org/apache/rocketmq/broker/processor/PopReviveService.java
+++
b/broker/src/main/java/org/apache/rocketmq/broker/processor/PopReviveService.java
@@ -322,7 +322,7 @@ public class PopReviveService extends ServiceThread {
if (endTime != 0 && System.currentTimeMillis() - endTime > 3 *
PopAckConstants.SECOND && timerDelay <= 0 && commitLogDelay <= 0) {
endTime = System.currentTimeMillis();
}
- POP_LOGGER.info("reviveQueueId={}, offset is {}, can not get
new msg, old endTime {}, new endTime {}, timerDelay={}, commitLogDelay={} ",
+ POP_LOGGER.debug("reviveQueueId={}, offset is {}, can not get
new msg, old endTime {}, new endTime {}, timerDelay={}, commitLogDelay={} ",
queueId, offset, old, endTime, timerDelay, commitLogDelay);
if (endTime - firstRt > PopAckConstants.ackTimeInterval +
PopAckConstants.SECOND) {
break;
@@ -528,7 +528,7 @@ public class PopReviveService extends ServiceThread {
GetMessageStatus getMessageStatus =
resultPair.getObject1();
MessageExt message = resultPair.getObject2();
if (message == null) {
- POP_LOGGER.warn("reviveQueueId={}, can not get biz msg
topic is {}, offset is {}, then continue",
+ POP_LOGGER.debug("reviveQueueId={}, can not get biz
msg topic is {}, offset is {}, then continue",
queueId, popCheckPoint.getTopic(), msgOffset);
switch (getMessageStatus) {
case MESSAGE_WAS_REMOVING:
