◆ clone()
Create a new instance of KeySharedPolicy with the same initial settings as the current one.
◆ getKeySharedMode()
| KeySharedMode pulsar::KeySharedPolicy::getKeySharedMode |
( |
| ) |
const |
- Returns
- the KeySharedMode of KeyShared subscription
◆ getStickyRanges()
| StickyRanges pulsar::KeySharedPolicy::getStickyRanges |
( |
| ) |
const |
- Returns
- ranges used with sticky mode
◆ isAllowOutOfOrderDelivery()
| bool pulsar::KeySharedPolicy::isAllowOutOfOrderDelivery |
( |
| ) |
const |
- Returns
- true if out of order delivery is enabled
◆ setAllowOutOfOrderDelivery()
| KeySharedPolicy & pulsar::KeySharedPolicy::setAllowOutOfOrderDelivery |
( |
bool |
allowOutOfOrderDelivery | ) |
|
If it is enabled, it relaxes the ordering requirement and allows the broker to send out-of-order messages in case of failures. This makes it faster for new consumers to join without being stalled by an existing slow consumer.
In this case, a single consumer still receives all keys, but they may come in different orders.
- Parameters
-
| allowOutOfOrderDelivery | whether to allow for out of order delivery |
◆ setKeySharedMode()
Configure the KeyShared mode of KeyShared subscription
- Parameters
-
- See also
KeySharedMode
◆ setStickyRanges() [1/2]
| KeySharedPolicy & pulsar::KeySharedPolicy::setStickyRanges |
( |
const StickyRanges & |
ranges | ) |
|
- Parameters
-
| ranges | used with sticky mode |
◆ setStickyRanges() [2/2]
| KeySharedPolicy & pulsar::KeySharedPolicy::setStickyRanges |
( |
std::initializer_list< StickyRange > |
ranges | ) |
|
- Parameters
-
| ranges | used with sticky mode |
- Deprecated:
- use the function that takes StickyRanges instead of std::initializer_list
The documentation for this class was generated from the following file:
