Package org.apache.pulsar.client.api

Class KeySharedPolicy.KeySharedPolicySticky

java.lang.Object

org.apache.pulsar.client.api.KeySharedPolicy

org.apache.pulsar.client.api.KeySharedPolicy.KeySharedPolicySticky

Enclosing class:

KeySharedPolicy

public static class KeySharedPolicy.KeySharedPolicySticky
extends KeySharedPolicy

Sticky attach topic with fixed hash range.

Total hash range size is 65536, using the sticky hash range policy should ensure that the provided ranges by all consumers can cover the total hash range [0, 65535]. If not, while broker dispatcher can't find the consumer for message, the cursor will rewind.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.pulsar.client.api.KeySharedPolicy

KeySharedPolicy.KeySharedPolicyAutoSplit, KeySharedPolicy.KeySharedPolicySticky

Field Summary

Fields

Modifier and Type	Field	Description
protected final List<Range>	ranges

Fields inherited from class org.apache.pulsar.client.api.KeySharedPolicy

allowOutOfOrderDelivery, DEFAULT_HASH_RANGE_SIZE, keySharedMode

Method Summary

Modifier and Type	Method	Description
List<Range>	getRanges()
KeySharedPolicy.KeySharedPolicySticky	ranges(List<Range> ranges)
KeySharedPolicy.KeySharedPolicySticky	ranges(Range... ranges)
void	validate()

Methods inherited from class org.apache.pulsar.client.api.KeySharedPolicy

autoSplitHashRange, getHashRangeTotal, getKeySharedMode, isAllowOutOfOrderDelivery, setAllowOutOfOrderDelivery, stickyHashRange

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

ranges

protected final List<Range> ranges

Method Details

ranges

public KeySharedPolicy.KeySharedPolicySticky ranges(List<Range> ranges)

ranges

public KeySharedPolicy.KeySharedPolicySticky ranges(Range... ranges)

validate

public void validate()

Specified by:

validate in class KeySharedPolicy

getRanges

public List<Range> getRanges()