@PublicEvolving public static class FixedKeysRangeGenerator.FixedKeysRangeGeneratorBuilder extends Object
FixedKeysRangeGenerator
.Modifier and Type | Method and Description |
---|---|
FixedKeysRangeGenerator |
build()
Create the FixedKeysRangeGenerator by the given keys.
|
FixedKeysRangeGenerator.FixedKeysRangeGeneratorBuilder |
key(String key)
If you set the message key by using
PulsarMessageBuilder.key(String) or TypedMessageBuilder.key(String) , use this method for supporting consuming such messages. |
FixedKeysRangeGenerator.FixedKeysRangeGeneratorBuilder |
keyBytes(byte[] keyBytes)
If you set the message key by using
TypedMessageBuilder.keyBytes(byte[]) , use
this method for supporting consuming such messages. |
FixedKeysRangeGenerator.FixedKeysRangeGeneratorBuilder |
keys(Collection<String> someKeys)
Same as the
key(String) , support setting multiple keys in the same time. |
FixedKeysRangeGenerator.FixedKeysRangeGeneratorBuilder |
keySharedMode(RangeGenerator.KeySharedMode sharedMode)
Override the default
KeySharedMode#JOIN to the mode your have provided. |
FixedKeysRangeGenerator.FixedKeysRangeGeneratorBuilder |
orderingKey(byte[] keyBytes)
Pulsar's ordering key is prior to the message key.
|
FixedKeysRangeGenerator.FixedKeysRangeGeneratorBuilder |
supportNullKey()
Some
Message in Pulsar may not have Message.getOrderingKey() or Message.getKey() , use this method for supporting consuming such messages. |
public FixedKeysRangeGenerator.FixedKeysRangeGeneratorBuilder supportNullKey()
Message
in Pulsar may not have Message.getOrderingKey()
or Message.getKey()
, use this method for supporting consuming such messages.public FixedKeysRangeGenerator.FixedKeysRangeGeneratorBuilder key(String key)
PulsarMessageBuilder.key(String)
or TypedMessageBuilder.key(String)
, use this method for supporting consuming such messages.public FixedKeysRangeGenerator.FixedKeysRangeGeneratorBuilder keys(Collection<String> someKeys)
key(String)
, support setting multiple keys in the same time.public FixedKeysRangeGenerator.FixedKeysRangeGeneratorBuilder keyBytes(byte[] keyBytes)
TypedMessageBuilder.keyBytes(byte[])
, use
this method for supporting consuming such messages.public FixedKeysRangeGenerator.FixedKeysRangeGeneratorBuilder orderingKey(byte[] keyBytes)
PulsarMessageBuilder.orderingKey(byte[])
or TypedMessageBuilder.orderingKey(byte[])
, use this method for supporting consuming such
messages.public FixedKeysRangeGenerator.FixedKeysRangeGeneratorBuilder keySharedMode(RangeGenerator.KeySharedMode sharedMode)
KeySharedMode#JOIN
to the mode your have provided.public FixedKeysRangeGenerator build()
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.