From 1042916cdc71d9a85534bac20f07edb0ee09d782 Mon Sep 17 00:00:00 2001 From: Naah Date: Wed, 26 Apr 2023 04:08:44 +0000 Subject: [PATCH] add rocketmq consumer config item description Signed-off-by: Naah --- .../supported-pubsub/setup-rocketmq.md | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/daprdocs/content/en/reference/components-reference/supported-pubsub/setup-rocketmq.md b/daprdocs/content/en/reference/components-reference/supported-pubsub/setup-rocketmq.md index c40d75e3d..403aa645d 100644 --- a/daprdocs/content/en/reference/components-reference/supported-pubsub/setup-rocketmq.md +++ b/daprdocs/content/en/reference/components-reference/supported-pubsub/setup-rocketmq.md @@ -58,12 +58,20 @@ The above example uses secrets as plain strings. It is recommended to use a secr | producerQueueSelector (queueSelector) | N | Producer Queue selector. There are five implementations of queue selector: `hash`, `random`, `manual`, `roundRobin`, `dapr`. | `dapr` | `hash` | | consumerModel | N | Message model that defines how messages are delivered to each consumer client. RocketMQ supports two message models: `clustering` and `broadcasting`. | `clustering` | `broadcasting` , `clustering` | | fromWhere (consumeFromWhere) | N | Consuming point on consumer booting. There are three consuming points: `CONSUME_FROM_LAST_OFFSET`, `CONSUME_FROM_FIRST_OFFSET`, `CONSUME_FROM_TIMESTAMP` | `CONSUME_FROM_LAST_OFFSET` | `CONSUME_FROM_LAST_OFFSET` | +| consumeTimestamp | N | Backtracking consumption time with second precision. Time format is `20131223171201`.Implying Seventeen twelve and 01 seconds on December 23, 2013 year | ` time.Now().Add(time.Minute * (-30)).Format("20060102150405")` | `20131223171201` | | consumeOrderly | N | Determines if it's an ordered message using FIFO order. | `false` | `false` | | consumeMessageBatchMaxSize | N | Batch consumption size out of range `[1, 1024]` | `512` | `10` | +| consumeConcurrentlyMaxSpan | N | Concurrently max span offset.it has no effect on sequential consumption.Range: `[1, 65535]` | `1000` | `1000` | | maxReconsumeTimes | N | Max re-consume times. `-1` means 16 times. If messages are re-consumed more than {@link maxReconsumeTimes} before success, they'll be directed to a deletion queue. | Orderly message is `MaxInt32`; Concurrently message is `16` | `16` | | autoCommit | N | Enable auto commit | `true` | `false` | +| consumeTimeout | N | Maximum amount of time a message may block the consuming thread.Time unit: Minute | `15` | `15` | +| consumerPullTimeout | N | The socket timeout in milliseconds | | | | pullInterval | N | Message pull interval | `100` | `100` | | pullBatchSize | N | The number of messages pulled from the broker at a time. If `pullBatchSize` is `null`, use `ConsumerBatchSize`. `pullBatchSize` out of range `[1, 1024]` | `32` | `10` | +| pullThresholdForQueue | N | Flow control threshold on queue level, each message queue will cache at most 1000 messages by default.Consider the `PullBatchSize`, the instantaneous value may exceed the limit.Range: `[1, 65535]` | `1024` | `1000` | +| pullThresholdForTopic | N | Flow control threshold on topic level.The value of `pullThresholdForQueue` will be overwritten and calculated based on`pullThresholdForTopic` if it isn't unlimited.For example, if the value of pullThresholdForTopic is 1000 and 10 message queues are assigned to this consumer,then pullThresholdForQueue will be set to 100.Range: `[1, 6553500]` | `-1(Unlimited)` | `10` | +| pullThresholdSizeForQueue | N | Limit the cached message size on queue level.Consider the `pullBatchSize`, the instantaneous value may exceed the limit.The size of a message only measured by message body, so it's not accurate.Range: `[1, 1024]` | `100` | `100` | +| pullThresholdSizeForTopic | N | Limit the cached message size on topic level.The value of `pullThresholdSizeForQueue` will be overwritten and calculated based on `pullThresholdSizeForTopic` if it isn't unlimited.For example, if the value of pullThresholdSizeForTopic is 1000 MiB and 10 message queues are assigned to this consumer, then pullThresholdSizeForQueue will be set to 100 MiB.Range: `[1, 102400]` | `-1` | `100` | | content-type | N | Message content type. | `"text/plain"` | `"application/cloudevents+json; charset=utf-8"`, `"application/octet-stream"` | | logLevel | N | Log level | `warn` | `info` | | sendTimeOut | N | Send message timeout to connect RocketMQ's broker, measured in nanoseconds. **Deprecated**. | 3 seconds | `10000000000` | @@ -147,4 +155,4 @@ If the `ShardingKey` does not exist, the `RoundRobin` algorithm is used to deter - [Basic schema for a Dapr component]({{< ref component-schema >}}) - [Pub/Sub building block]({{< ref pubsub >}}) -- Read [this guide]({{< ref "howto-publish-subscribe.md#step-2-publish-a-topic" >}}) for instructions on configuring pub/sub components +- Read [this guide]({{< ref "howto-publish-subscribe.md#step-2-publish-a-topic" >}}) for instructions on configuring pub/sub components \ No newline at end of file