Skip to content

Commit cdae684

Browse files
authored
Merge pull request #5115 from MyMirelHub/pulsar-additional-meta
Add missing configuration options for Pulsar component
2 parents 2d238ac + 6ff684b commit cdae684

1 file changed

Lines changed: 4 additions & 0 deletions

File tree

  • daprdocs/content/en/reference/components-reference/supported-pubsub

daprdocs/content/en/reference/components-reference/supported-pubsub/setup-pulsar.md

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -81,11 +81,15 @@ The above example uses secrets as plain strings. It is recommended to use a [sec
8181
| persistent | N | Pulsar supports two kinds of topics: [persistent](https://pulsar.apache.org/docs/en/concepts-architecture-overview#persistent-storage) and [non-persistent](https://pulsar.apache.org/docs/en/concepts-messaging/#non-persistent-topics). With persistent topics, all messages are durably persisted on disks (if the broker is not standalone, messages are durably persisted on multiple disks), whereas data for non-persistent topics is not persisted to storage disks.
8282
| disableBatching | N | disable batching.When batching enabled default batch delay is set to 10 ms and default batch size is 1000 messages,Setting `disableBatching: true` will make the producer to send messages individually. Default: `"false"` | `"true"`, `"false"`|
8383
| receiverQueueSize | N | Sets the size of the consumer receiver queue. Controls how many messages can be accumulated by the consumer before it is explicitly called to read messages by Dapr. Default: `"1000"` | `"1000"` |
84+
| redeliveryDelay | N | Delay before redelivering a message that was not acknowledged by the app. Default: `"30s"` | `"30s"`, `"200ms"` |
8485
| batchingMaxPublishDelay | N | batchingMaxPublishDelay set the time period within which the messages sent will be batched,if batch messages are enabled. If set to a non zero value, messages will be queued until this time interval or batchingMaxMessages (see below) or batchingMaxSize (see below). There are two valid formats, one is the fraction with a unit suffix format, and the other is the pure digital format that is processed as milliseconds. Valid time units are "ns", "us" (or "µs"), "ms", "s", "m", "h". Default: `"10ms"` | `"10ms"`, `"10"`|
8586
| batchingMaxMessages | N | batchingMaxMessages set the maximum number of messages permitted in a batch.If set to a value greater than 1, messages will be queued until this threshold is reached or batchingMaxSize (see below) has been reached or the batch interval has elapsed. Default: `"1000"` | `"1000"`|
8687
| batchingMaxSize | N | batchingMaxSize sets the maximum number of bytes permitted in a batch. If set to a value greater than 1, messages will be queued until this threshold is reached or batchingMaxMessages (see above) has been reached or the batch interval has elapsed. Default: `"128KB"` | `"131072"`|
88+
| compressionType | N | Sets the compression type for messages sent by the producer. Default: `"none"` | `"none"`, `"lz4"`, `"zlib"`, `"zstd"` |
89+
| compressionLevel | N | Sets the compression level used when `compressionType` is enabled. Default: `"default"` | `"default"`, `"faster"`, `"better"` |
8790
| <topic-name>.jsonschema | N | Enforces JSON schema validation for the configured topic. |
8891
| <topic-name>.avroschema | N | Enforces Avro schema validation for the configured topic. |
92+
| <topic-name>.rawschema | N | Registers the provided Avro or JSON schema as-is instead of wrapping it in a CloudEvents envelope schema. Default: `"false"` | `"true"`, `"false"` |
8993
| publicKey | N | A public key to be used for publisher and consumer encryption. Value can be one of two options: file path for a local PEM cert, or the cert data string value |
9094
| privateKey | N | A private key to be used for consumer encryption. Value can be one of two options: file path for a local PEM cert, or the cert data string value |
9195
| 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 |

0 commit comments

Comments
 (0)