Package | Description |
---|---|
org.apache.flink.connector.pulsar.source.enumerator.topic.range |
Modifier and Type | Method and Description |
---|---|
static FixedKeysRangeGenerator.FixedKeysRangeGeneratorBuilder |
FixedKeysRangeGenerator.builder() |
FixedKeysRangeGenerator.FixedKeysRangeGeneratorBuilder |
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 |
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 |
FixedKeysRangeGenerator.FixedKeysRangeGeneratorBuilder.keys(Collection<String> someKeys)
Same as the
key(String) , support setting multiple keys in the same time. |
FixedKeysRangeGenerator.FixedKeysRangeGeneratorBuilder |
FixedKeysRangeGenerator.FixedKeysRangeGeneratorBuilder.keySharedMode(RangeGenerator.KeySharedMode sharedMode)
Override the default
KeySharedMode#JOIN to the mode your have provided. |
FixedKeysRangeGenerator.FixedKeysRangeGeneratorBuilder |
FixedKeysRangeGenerator.FixedKeysRangeGeneratorBuilder.orderingKey(byte[] keyBytes)
Pulsar's ordering key is prior to the message key.
|
FixedKeysRangeGenerator.FixedKeysRangeGeneratorBuilder |
FixedKeysRangeGenerator.FixedKeysRangeGeneratorBuilder.supportNullKey()
Some
Message in Pulsar may not have Message.getOrderingKey() or Message.getKey() , use this method for supporting consuming such messages. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.