Modifier and Type | Method and Description |
---|---|
PulsarSourceBuilder<OUT> |
PulsarSourceBuilder.setStartCursor(StartCursor startCursor)
Specify from which offsets the PulsarSource should start consume from by providing an
StartCursor . |
Constructor and Description |
---|
PulsarSourceEnumerator(PulsarSubscriber subscriber,
StartCursor startCursor,
StopCursor stopCursor,
RangeGenerator rangeGenerator,
SourceConfiguration sourceConfiguration,
SplitEnumeratorContext<PulsarPartitionSplit> context) |
PulsarSourceEnumerator(PulsarSubscriber subscriber,
StartCursor startCursor,
StopCursor stopCursor,
RangeGenerator rangeGenerator,
SourceConfiguration sourceConfiguration,
SplitEnumeratorContext<PulsarPartitionSplit> context,
PulsarSourceEnumState enumState) |
Modifier and Type | Method and Description |
---|---|
static StartCursor |
StartCursor.defaultStartCursor() |
static StartCursor |
StartCursor.earliest() |
static StartCursor |
StartCursor.fromMessageId(org.apache.pulsar.client.api.MessageId messageId)
Find the available message id and start consuming from it.
|
static StartCursor |
StartCursor.fromMessageId(org.apache.pulsar.client.api.MessageId messageId,
boolean inclusive) |
static StartCursor |
StartCursor.fromMessageTime(long timestamp)
Deprecated.
Use
fromPublishTime(long) instead. |
static StartCursor |
StartCursor.fromPublishTime(long timestamp)
Seek the start position by using message publish time.
|
static StartCursor |
StartCursor.latest() |
Modifier and Type | Class and Description |
---|---|
class |
MessageIdStartCursor
This cursor would leave pulsar start consuming from a specific message id.
|
class |
TimestampStartCursor
This cursor would left pulsar start consuming from a specific publish timestamp.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.