[rocketmq-eventbridge] branch main updated: bugfix:fix new group init offset issue

[shenlin]

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

shenlin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git


The following commit(s) were added to refs/heads/main by this push:
     new 722f124  bugfix:fix new group init offset issue
722f124 is described below

commit 722f124a43e5dceec2564fcf72b972ca83f5112a
Author: changfeng <yongming....@alibaba-inc.com>
AuthorDate: Mon Jun 26 10:37:45 2023 +0800

    bugfix:fix new group init offset issue
---
 .../adapter/storage/rocketmq/runtimer/consumer/LocalMessageCache.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/LocalMessageCache.java
 
b/adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/LocalMessageCache.java
index b4cf7a7..7d1c1af 100644
--- 
a/adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/LocalMessageCache.java
+++ 
b/adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/LocalMessageCache.java
@@ -90,7 +90,7 @@ public class LocalMessageCache {
                             break;
                     }
                 }
-                if (offset > 0) {
+                if (offset >= 0) {
                     // Got an offset from offset store
                     return offset;
                 }