You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by du...@apache.org on 2022/09/29 06:19:38 UTC
[rocketmq-site] branch new-official-website updated: New official website develop (#288)
This is an automated email from the ASF dual-hosted git repository.
duhengforever pushed a commit to branch new-official-website
in repository https://gitbox.apache.org/repos/asf/rocketmq-site.git
The following commit(s) were added to refs/heads/new-official-website by this push:
new 6dff5543 New official website develop (#288)
6dff5543 is described below
commit 6dff55434a96da603983712d4d1b108f51a42742
Author: Heng Du <du...@apache.org>
AuthorDate: Thu Sep 29 14:19:34 2022 +0800
New official website develop (#288)
* [ISSUE #248] Remove redundant character (#250)
* [ISSUE #248] Remove redundant character
* remove redundant symbol
* [ISSUE #276]Fix Rocketmq5.0 quick start document display format problem (#285)
Co-authored-by: Oliver <wq...@163.com>
Co-authored-by: mxsm <lj...@gmail.com>
---
"docs/02-\347\224\237\344\272\247\350\200\205/09message5.md" | 2 +-
.../02quickstart.md" | 7 ++++---
.../09consumerprogress.md" | 2 +-
3 files changed, 6 insertions(+), 5 deletions(-)
diff --git "a/docs/02-\347\224\237\344\272\247\350\200\205/09message5.md" "b/docs/02-\347\224\237\344\272\247\350\200\205/09message5.md"
index 77936a35..9cb74a02 100644
--- "a/docs/02-\347\224\237\344\272\247\350\200\205/09message5.md"
+++ "b/docs/02-\347\224\237\344\272\247\350\200\205/09message5.md"
@@ -158,6 +158,6 @@ public interface TransactionListener {
:::caution
-此外,需要注意的是事务消息的生产组名称 ProducerGroupName不能随意设置。事务消息有回查机制,回查时Broker端如果发现原始生产者已经崩溃崩溃,则会联系同一生产者组的其他生产者实例回查本地事务执行情况以Commit或Rollback半事务消息。
+此外,需要注意的是事务消息的生产组名称 ProducerGroupName不能随意设置。事务消息有回查机制,回查时Broker端如果发现原始生产者已经崩溃,则会联系同一生产者组的其他生产者实例回查本地事务执行情况以Commit或Rollback半事务消息。
:::
\ No newline at end of file
diff --git "a/versioned_docs/version-5.0/02-\345\277\253\351\200\237\345\205\245\351\227\250/02quickstart.md" "b/versioned_docs/version-5.0/02-\345\277\253\351\200\237\345\205\245\351\227\250/02quickstart.md"
index 908d0ed1..13b731b8 100644
--- "a/versioned_docs/version-5.0/02-\345\277\253\351\200\237\345\205\245\351\227\250/02quickstart.md"
+++ "b/versioned_docs/version-5.0/02-\345\277\253\351\200\237\345\205\245\351\227\250/02quickstart.md"
@@ -101,11 +101,12 @@ $ sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
<version>5.0.0</version>
</dependency>
```
+
3. 通过mqadmin创建 Topic。
-```shell
-$ sh bin/mqadmin updatetopic -n localhost:9876 -t TestTopic
-```
+ ```shell
+ $ sh bin/mqadmin updatetopic -n localhost:9876 -t TestTopic
+ ```
4. 在已创建的Java工程中,创建发送普通消息程序并运行,示例代码如下:
diff --git "a/versioned_docs/version-5.0/04-\345\212\237\350\203\275\350\241\214\344\270\272/09consumerprogress.md" "b/versioned_docs/version-5.0/04-\345\212\237\350\203\275\350\241\214\344\270\272/09consumerprogress.md"
index 81ea6d0d..0477a526 100644
--- "a/versioned_docs/version-5.0/04-\345\212\237\350\203\275\350\241\214\344\270\272/09consumerprogress.md"
+++ "b/versioned_docs/version-5.0/04-\345\212\237\350\203\275\350\241\214\344\270\272/09consumerprogress.md"
@@ -44,7 +44,7 @@ Apache RocketMQ 领域模型为发布订阅模式,每个主题的队列都可
* ConsumerOffset≤MaxOffset:
* 当消费速度和生产速度一致,且全部消息都处理完成时,最大消息位点和消费位点相同,即ConsumerOffset=MaxOffset。
- * 当消费速度较慢小于生产速度时,队列中会有部分消息未消费,此时消费位点小于最大消息位点,即ConsumerOffset\<MaxOffset,两者之差就是该队列中堆积的消息量。
+ * 当消费速度较慢小于生产速度时,队列中会有部分消息未消费,此时消费位点小于最大消息位点,即ConsumerOffset<MaxOffset,两者之差就是该队列中堆积的消息量。
* ConsumerOffset≥MinOffset:正常情况下有效的消费位点ConsumerOffset必然大于等于最小消息位点MinOffset。消费位点小于最小消息位点时是无效的,相当于消费者要消费的消息已经从队列中删除了,是无法消费到的,此时服务端会将消费位点强制纠正到合法的消息位点。