From 09c0c8ce78670aa34d11f028510162d9f300e497 Mon Sep 17 00:00:00 2001 From: "fujian.zfj" Date: Tue, 30 Nov 2021 20:19:07 +0800 Subject: [PATCH 1/2] typo int readme[ecosystem] --- README.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/README.md b/README.md index eb20e798ea9..79b316c2987 100644 --- a/README.md +++ b/README.md @@ -18,7 +18,7 @@ It offers a variety of features: * A variety of cross language clients, such as Java, [C/C++](https://github.com/apache/rocketmq-client-cpp), [Python](https://github.com/apache/rocketmq-client-python), [Go](https://github.com/apache/rocketmq-client-go), [Node.js](https://github.com/apache/rocketmq-client-nodejs) * Pluggable transport protocols, such as TCP, SSL, AIO * Built-in message tracing capability, also support opentracing -* Versatile big-data and streaming ecosytem integration +* Versatile big-data and streaming ecosystem integration * Message retroactivity by time or offset * Reliable FIFO and strict ordered messaging in the same queue * Efficient pull and push consumption model From 0953c2fa93d71ea8c8a850c746da0bb16ae98f6c Mon Sep 17 00:00:00 2001 From: zfj Date: Tue, 10 Oct 2023 19:53:07 +0800 Subject: [PATCH 2/2] 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 456bf2b86f0..f98e9a284aa 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 long getConfirmOffset() { 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); }