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