[rocketmq] branch develop updated: [ISSUE #7441] Fix log "Init the confirmOffset" keep printing error in controller mode (#7442)

[jinrongtong]

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

jinrongtong 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 7e4879a3bc [ISSUE #7441] Fix log "Init the confirmOffset" keep 
printing error in controller mode (#7442)
7e4879a3bc is described below

commit 7e4879a3bc120d6289aabc8354a2811f349ac8a6
Author: fujian-zfj <2573259...@qq.com>
AuthorDate: Wed Oct 11 14:45:07 2023 +0800

    [ISSUE #7441] Fix log "Init the confirmOffset" keep printing error in 
controller mode (#7442)
    
    * typo int readme[ecosystem]
    
    * fix keep printing log problem
---
 store/src/main/java/org/apache/rocketmq/store/CommitLog.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/store/src/main/java/org/apache/rocketmq/store/CommitLog.java 
b/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
index 456bf2b86f..f98e9a284a 100644
--- a/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
+++ b/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
@@ -580,7 +580,7 @@ public class CommitLog implements Swappable {
                     return this.defaultMessageStore.getMaxPhyOffset();
                 }
                 // First time it will compute the confirmOffset.
-                if (this.confirmOffset <= 0) {
+                if (this.confirmOffset < 0) {
                     setConfirmOffset(((AutoSwitchHAService) 
this.defaultMessageStore.getHaService()).computeConfirmOffset());
                     log.info("Init the confirmOffset to {}.", 
this.confirmOffset);
                 }