(rocketmq) branch develop updated: [ISSUE #9249] When delivery fails, there is an incorrect start offset in the delivery settings

[lizhimin]

This is an automated email from the ASF dual-hosted git repository.

lizhimin 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 b695652003 [ISSUE #9249] When delivery fails, there is an incorrect 
start offset in the delivery settings
b695652003 is described below

commit b69565200364ffb0ccf911718ab9e8bc7ca0e1e7
Author: Liu JinJie <39191987+coolmoon...@users.noreply.github.com>
AuthorDate: Mon Mar 17 15:49:24 2025 +0800

    [ISSUE #9249] When delivery fails, there is an incorrect start offset in 
the delivery settings
---
 .../org/apache/rocketmq/broker/schedule/ScheduleMessageService.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 70184e8a62..a5b02c9a63 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 class ScheduleMessageService extends ConfigManager {
                     }
 
                     if (!deliverSuc) {
-                        this.scheduleNextTimerTask(nextOffset, 
DELAY_FOR_A_WHILE);
+                        this.scheduleNextTimerTask(currOffset, 
DELAY_FOR_A_WHILE);
                         return;
                     }
                 }