You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ji...@apache.org on 2023/01/17 02:53:41 UTC

[rocketmq-site] branch new-official-website updated: Improve the valid values ​​of some parameters in the client document (#450)

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

jinrongtong 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 1b633889b Improve the valid values ​​of some parameters in the client document (#450)
1b633889b is described below

commit 1b633889b397546928ee490c0ebab8c85732de44
Author: windWheel <18...@qq.com>
AuthorDate: Tue Jan 17 10:53:36 2023 +0800

    Improve the valid values ​​of some parameters in the client document (#450)
---
 docs/06-parameterConfiguration/23local.md | 12 +++++-------
 1 file changed, 5 insertions(+), 7 deletions(-)

diff --git a/docs/06-parameterConfiguration/23local.md b/docs/06-parameterConfiguration/23local.md
index ae0a8e785..ee9d29ac2 100644
--- a/docs/06-parameterConfiguration/23local.md
+++ b/docs/06-parameterConfiguration/23local.md
@@ -87,13 +87,13 @@ DefaultMQProducer、TransactionMQProducer、DefaultMQPushConsumer、DefaultMQPul
 | 名称                               | 描述                                                         | 参数类型                     | 默认值                                              | 有效值 | 重要性 |
 | ---------------------------------- | ------------------------------------------------------------ | ---------------------------- | --------------------------------------------------- | ------ | ------ |
 | consumerGroup                      | 消费组的名称,用于标识一类消费者                             | String                       |                                                     |        |        |
-| messageModel                       | 消费模式                                                     | MessageModel                 | MessageModel.CLUSTERINGallocateMessageQueueStrategy |        |        |
+| messageModel                       | 消费模式                                                     | MessageModel                 | MessageModel.CLUSTERINGallocateMessageQueueStrategy |    CLUSTERING(集群消費模式) / ROADCASTING (广播消费模式)    |        |
 | consumeFromWhere                   | 启动消费点策略                                               | ConsumeFromWhere             | ConsumeFromWhere.CONSUME_FROM_LAST_OFFSET           |        |        |
 | consumeTimestamp                   | CONSUME_FROM_LAST_OFFSET的时候使用,从哪个时间点开始消费     | String                       | 半小时前                                            |        |        |
 | allocateMessageQueueStrategy       | 负载均衡策略算法                                             | AllocateMessageQueueStrategy | AllocateMessageQueueAveragely(取模平均分配)       |        |        |
 | subscription                       | 订阅关系                                                     | Map<String, String>          | {}                                                  |        |        |
 | messageListener                    | 消息处理监听器(回调)                                       | MessageListener              | null                                                |        |        |
-| offsetStore                        | 消息消费进度存储器                                           | OffsetStore                  | null                                                |        |        |
+| offsetStore                        | 消息消费进度存储器                                           | OffsetStore                  | null                                                |     不建议设置,offsetStore 有两个策略:LocalFileOffsetStore 和RemoteBrokerOffsetStore.若沒有显示设置的情況下,广播模式將使用LocalFileOffsetStore,集群模式將使用RemoteBrokerOffsetStore,不建议修改.   |        |
 | consumeThreadMin                   | 消费线程池的core size                                        | int                          | 20                                                  |        |        |
 | consumeThreadMax                   | 消费线程池的max size                                         | int                          | 64                                                  |        |        |
 | adjustThreadPoolNumsThreshold      | 动态扩线程核数的消费堆积阈值                                 | long                         | 100000                                              |        |        |
@@ -106,12 +106,12 @@ DefaultMQProducer、TransactionMQProducer、DefaultMQPushConsumer、DefaultMQPul
 | consumeMessageBatchMaxSize         | 批量消费的最大消息条数                                       | int                          | -1                                                  |        |        |
 | postSubscriptionWhenPull           | 每次拉取的时候是否更新订阅关系                               | boolean                      | false                                               |        |        |
 | unitMode                           | 订阅组的单位                                                 | boolean                      | false                                               |        |        |
-| maxReconsumeTimes                  | 一个消息如果消费失败的话,最多重新消费多少次才投递到死信队列 | int                          | -1                                                  |        |        |
+| maxReconsumeTimes                  | 一个消息如果消费失败的话,最多重新消费多少次才投递到死信队列 | int                          | -1                                                  |    由于PullConsumer没有管理消费的线程池和管理器,需要用户自己处理各种消费结果和拉取结果,故需要投递到重试队列或死信队列的时候需要显示调用sendMessageBack.回传消息的时候会带上maxReconsumeTimes的值,broker发现此消息已经消费超过此值,则投递到死信队列,否则投递到重试队列。此逻辑和DefaultPushConsumer是一致的,只是PushConsumer无需用户显示调用.    |        |
 | suspendCurrentQueueTimeMillis      | 串行消费使用,如果返回ROLLBACK或者SUSPEND_CURRENT_QUEUE_A_MOMENT,再次消费的时间间隔 | long                         | 1000                                                |        |        |
 | consumeTimeout                     | 消费的最长超时时间                                           | long                         | 15,单位分钟                                        |        |        |
 | awaitTerminationMillisWhenShutdown | 关闭使用者时等待消息的最长时间,0表示无等待。                | long                         | 0                                                   |        |        |
 | traceDispatcher                    | 异步传输数据接口                                             | TraceDispatcher              | null                                                |        |        |
-
+| registerTopics                     | 消費者需要監聽的topic                                        | Collection                        | 默認值:空集合
 
 
 ## DefaultLitePullConsumer配置
@@ -142,6 +142,4 @@ DefaultMQProducer、TransactionMQProducer、DefaultMQPushConsumer、DefaultMQPul
 | consumeTimestamp                 | 回溯消费时间                                             | String                       | 默认回溯消耗时间为半小时前                    |        |        |
 | traceDispatcher                  | 异步传输数据的接口                                       | TraceDispatcher              | null                                          |        |        |
 | enableMsgTrace                   | 信息跟踪的标志                                           | boolean                      | false                                         |        |        |
-| customizedTraceTopic             | 消息跟踪主题的名称                                       | String                       |                                               |        |        |
-
-continue......
\ No newline at end of file
+| customizedTraceTopic             | 消息跟踪主题的名称                                       | String                       |                                               |        |        |
\ No newline at end of file