commit 722f124a43e5dceec2564fcf72b972ca83f5112a
author changfeng <yongming.cym@alibaba-inc.com> Mon Jun 26 10:37:45 2023 +0800
committer shenlin <2011shenlin@gmail.com> Mon Jun 26 11:47:10 2023 +0800
tree db1e425c8e11c208d0a080abfa7848f5b4c11315
parent c32edbe8c9c7bd9910efdc1ec325dcb58f790fd9

bugfix:fix new group init offset issue

adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/LocalMessageCache.java

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 @@
                             break;
                     }
                 }
-                if (offset > 0) {
+                if (offset >= 0) {
                     // Got an offset from offset store
                     return offset;
                 }