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" } },