From 18d14dd5a792324402b13f3ae46c99e14eac03b2 Mon Sep 17 00:00:00 2001 From: ericsyh Date: Tue, 18 Mar 2025 09:41:18 +0800 Subject: [PATCH 1/2] feat(pulsar): support subscribeInitialPosition on Pulsar consumer Signed-off-by: ericsyh --- .../components-reference/supported-pubsub/setup-pulsar.md | 1 + 1 file changed, 1 insertion(+) diff --git a/daprdocs/content/en/reference/components-reference/supported-pubsub/setup-pulsar.md b/daprdocs/content/en/reference/components-reference/supported-pubsub/setup-pulsar.md index 5dc9261a7dd..543bf44cb2f 100644 --- a/daprdocs/content/en/reference/components-reference/supported-pubsub/setup-pulsar.md +++ b/daprdocs/content/en/reference/components-reference/supported-pubsub/setup-pulsar.md @@ -91,6 +91,7 @@ The above example uses secrets as plain strings. It is recommended to use a [sec | keys | N | A comma delimited string containing names of [Pulsar session keys](https://pulsar.apache.org/docs/3.0.x/security-encryption/#how-it-works-in-pulsar). Used in conjunction with `publicKey` for publisher encryption | | processMode | N | Enable processing multiple messages at once. Default: `"async"` | `"async"`, `"sync"`| | subscribeType | N | Pulsar supports four kinds of [subscription types](https://pulsar.apache.org/docs/3.0.x/concepts-messaging/#subscription-types). Default: `"shared"` | `"shared"`, `"exclusive"`, `"failover"`, `"key_shared"`| +| subscribeInitialPosition | N | Subscription position is the initial position which the cursor will be set when start consuming. Default: `"latest"` | `"latest"`, `"earliest"` | | partitionKey | N | Sets the key of the message for routing policy. Default: `""` | | | `maxConcurrentHandlers` | N | Defines the maximum number of concurrent message handlers. Default: `100` | `10` From 108545387a64a5629d9de6639fc11a5bd8da106e Mon Sep 17 00:00:00 2001 From: Eric Shen Date: Tue, 18 Mar 2025 14:49:20 +0800 Subject: [PATCH 2/2] Update daprdocs/content/en/reference/components-reference/supported-pubsub/setup-pulsar.md Co-authored-by: Mark Fussell Signed-off-by: Eric Shen --- .../components-reference/supported-pubsub/setup-pulsar.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/daprdocs/content/en/reference/components-reference/supported-pubsub/setup-pulsar.md b/daprdocs/content/en/reference/components-reference/supported-pubsub/setup-pulsar.md index 543bf44cb2f..39b36df6e0c 100644 --- a/daprdocs/content/en/reference/components-reference/supported-pubsub/setup-pulsar.md +++ b/daprdocs/content/en/reference/components-reference/supported-pubsub/setup-pulsar.md @@ -91,7 +91,7 @@ The above example uses secrets as plain strings. It is recommended to use a [sec | keys | N | A comma delimited string containing names of [Pulsar session keys](https://pulsar.apache.org/docs/3.0.x/security-encryption/#how-it-works-in-pulsar). Used in conjunction with `publicKey` for publisher encryption | | processMode | N | Enable processing multiple messages at once. Default: `"async"` | `"async"`, `"sync"`| | subscribeType | N | Pulsar supports four kinds of [subscription types](https://pulsar.apache.org/docs/3.0.x/concepts-messaging/#subscription-types). Default: `"shared"` | `"shared"`, `"exclusive"`, `"failover"`, `"key_shared"`| -| subscribeInitialPosition | N | Subscription position is the initial position which the cursor will be set when start consuming. Default: `"latest"` | `"latest"`, `"earliest"` | +| subscribeInitialPosition | N | Subscription position is the initial position which the cursor is set when start consuming. Default: `"latest"` | `"latest"`, `"earliest"` | | partitionKey | N | Sets the key of the message for routing policy. Default: `""` | | | `maxConcurrentHandlers` | N | Defines the maximum number of concurrent message handlers. Default: `100` | `10`