This is an automated email from the ASF dual-hosted git repository.
urfree pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pulsar-site.git
The following commit(s) were added to refs/heads/main by this push:
new f50533076843 Docs sync done from apache/pulsar (#77570d5)
f50533076843 is described below
commit f505330768433ea74eb27b48bcc4da112d9bfad4
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Thu Sep 19 01:39:28 2024 +0000
Docs sync done from apache/pulsar (#77570d5)
---
.../next/config/reference-configuration-broker.md | 30 +++++++++++++++++++++-
.../config/reference-configuration-standalone.md | 30 +++++++++++++++++++++-
static/swagger/master/swagger.json | 2 +-
static/swagger/master/v2/swagger.json | 2 +-
4 files changed, 60 insertions(+), 4 deletions(-)
diff --git a/static/reference/next/config/reference-configuration-broker.md
b/static/reference/next/config/reference-configuration-broker.md
index c715e1f1d246..356b242cefcf 100644
--- a/static/reference/next/config/reference-configuration-broker.md
+++ b/static/reference/next/config/reference-configuration-broker.md
@@ -1958,6 +1958,34 @@ Allow schema to be auto updated at broker level. User
can override this by 'is_a
**Category**: Policies
+### keySharedLookAheadMsgInReplayThresholdPerConsumer
+For Key_Shared subscriptions, if messages cannot be dispatched to consumers
due to a slow consumer or a blocked key hash (because of ordering constraints),
the broker will continue reading more messages from the backlog and attempt to
dispatch them to consumers until the number of replay messages reaches the
calculated threshold.
+Formula: threshold = min(keySharedLookAheadMsgInReplayThresholdPerConsumer *
connected consumer count,
keySharedLookAheadMsgInReplayThresholdPerSubscription).
+Setting this value to 0 will disable the limit calculated per consumer.
+
+**Type**: `int`
+
+**Default**: `2000`
+
+**Dynamic**: `true`
+
+**Category**: Policies
+
+### keySharedLookAheadMsgInReplayThresholdPerSubscription
+For Key_Shared subscriptions, if messages cannot be dispatched to consumers
due to a slow consumer or a blocked key hash (because of ordering constraints),
the broker will continue reading more messages from the backlog and attempt to
dispatch them to consumers until the number of replay messages reaches the
calculated threshold.
+Formula: threshold = min(keySharedLookAheadMsgInReplayThresholdPerConsumer *
connected consumer count,
keySharedLookAheadMsgInReplayThresholdPerSubscription).
+This value should be set to a value less than 2 *
managedLedgerMaxUnackedRangesToPersist.
+Setting this value to 0 will disable the limit calculated per subscription.
+
+
+**Type**: `int`
+
+**Default**: `20000`
+
+**Dynamic**: `true`
+
+**Category**: Policies
+
### maxConsumerMetadataSize
Maximum size of Consumer metadata
@@ -3409,7 +3437,7 @@ Max memory size for broker handling messages sending from
producers.
**Type**: `int`
-**Default**: `1998`
+**Default**: `1999`
**Dynamic**: `true`
diff --git a/static/reference/next/config/reference-configuration-standalone.md
b/static/reference/next/config/reference-configuration-standalone.md
index c715e1f1d246..356b242cefcf 100644
--- a/static/reference/next/config/reference-configuration-standalone.md
+++ b/static/reference/next/config/reference-configuration-standalone.md
@@ -1958,6 +1958,34 @@ Allow schema to be auto updated at broker level. User
can override this by 'is_a
**Category**: Policies
+### keySharedLookAheadMsgInReplayThresholdPerConsumer
+For Key_Shared subscriptions, if messages cannot be dispatched to consumers
due to a slow consumer or a blocked key hash (because of ordering constraints),
the broker will continue reading more messages from the backlog and attempt to
dispatch them to consumers until the number of replay messages reaches the
calculated threshold.
+Formula: threshold = min(keySharedLookAheadMsgInReplayThresholdPerConsumer *
connected consumer count,
keySharedLookAheadMsgInReplayThresholdPerSubscription).
+Setting this value to 0 will disable the limit calculated per consumer.
+
+**Type**: `int`
+
+**Default**: `2000`
+
+**Dynamic**: `true`
+
+**Category**: Policies
+
+### keySharedLookAheadMsgInReplayThresholdPerSubscription
+For Key_Shared subscriptions, if messages cannot be dispatched to consumers
due to a slow consumer or a blocked key hash (because of ordering constraints),
the broker will continue reading more messages from the backlog and attempt to
dispatch them to consumers until the number of replay messages reaches the
calculated threshold.
+Formula: threshold = min(keySharedLookAheadMsgInReplayThresholdPerConsumer *
connected consumer count,
keySharedLookAheadMsgInReplayThresholdPerSubscription).
+This value should be set to a value less than 2 *
managedLedgerMaxUnackedRangesToPersist.
+Setting this value to 0 will disable the limit calculated per subscription.
+
+
+**Type**: `int`
+
+**Default**: `20000`
+
+**Dynamic**: `true`
+
+**Category**: Policies
+
### maxConsumerMetadataSize
Maximum size of Consumer metadata
@@ -3409,7 +3437,7 @@ Max memory size for broker handling messages sending from
producers.
**Type**: `int`
-**Default**: `1998`
+**Default**: `1999`
**Dynamic**: `true`
diff --git a/static/swagger/master/swagger.json
b/static/swagger/master/swagger.json
index deb2fd163666..5dde7b6330a6 100644
--- a/static/swagger/master/swagger.json
+++ b/static/swagger/master/swagger.json
@@ -1824,7 +1824,7 @@
"none",
"changed"
],
- "example": "'all_matching' (default) for unloading all
matching namespaces. 'none' for not unloading any namespace. 'changed' for
unloading only the namespaces whose placement is actually changing",
+ "example": "'changed' (default) for unloading only the
namespaces whose placement is actually changing. 'all_matching' for unloading
all matching namespaces. 'none' for not unloading any namespaces.",
"type": "string"
}
},
diff --git a/static/swagger/master/v2/swagger.json
b/static/swagger/master/v2/swagger.json
index deb2fd163666..5dde7b6330a6 100644
--- a/static/swagger/master/v2/swagger.json
+++ b/static/swagger/master/v2/swagger.json
@@ -1824,7 +1824,7 @@
"none",
"changed"
],
- "example": "'all_matching' (default) for unloading all
matching namespaces. 'none' for not unloading any namespace. 'changed' for
unloading only the namespaces whose placement is actually changing",
+ "example": "'changed' (default) for unloading only the
namespaces whose placement is actually changing. 'all_matching' for unloading
all matching namespaces. 'none' for not unloading any namespaces.",
"type": "string"
}
},
