diff --git a/broker/src/main/java/org/apache/rocketmq/broker/schedule/ScheduleMessageService.java b/broker/src/main/java/org/apache/rocketmq/broker/schedule/ScheduleMessageService.java index 70184e8a620..a5b02c9a63c 100644 --- a/broker/src/main/java/org/apache/rocketmq/broker/schedule/ScheduleMessageService.java +++ b/broker/src/main/java/org/apache/rocketmq/broker/schedule/ScheduleMessageService.java @@ -474,7 +474,7 @@ public void executeOnTimeUp() { } if (!deliverSuc) { - this.scheduleNextTimerTask(nextOffset, DELAY_FOR_A_WHILE); + this.scheduleNextTimerTask(currOffset, DELAY_FOR_A_WHILE); return; } }