[ISSUE apache#8281] Optimize pop log level (apache#8282)

* change pop log level to debug when all the revive messages are handled
yx9o · Jun 13, 2024 · 3ac5c73 · 3ac5c73
1 parent 017b753
commit 3ac5c73
Showing 1 changed file with 2 additions and 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
@@ -322,7 +322,7 @@ protected void consumeReviveMessage(ConsumeReviveObj consumeReviveObj) {
                 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 @@ private void reviveMsgFromCk(PopCheckPoint popCheckPoint) {
                     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: