public class LatestMessageStopCursor extends Object implements StopCursor
PulsarPartitionSplitReaderBase
instead of by the PulsarSourceEnumerator
. We would include the latest message available in Pulsar by default.StopCursor.StopCondition
Constructor and Description |
---|
LatestMessageStopCursor(boolean inclusive) |
Modifier and Type | Method and Description |
---|---|
void |
open(org.apache.pulsar.client.admin.PulsarAdmin admin,
TopicPartition partition)
The open method for the cursor initializer.
|
StopCursor.StopCondition |
shouldStop(org.apache.pulsar.client.api.Message<?> message)
Determine whether to pause consumption on the current message by the returned enum.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
afterEventTime, afterMessageId, afterPublishTime, atEventTime, atMessageId, atPublishTime, defaultStopCursor, latest, never
public StopCursor.StopCondition shouldStop(org.apache.pulsar.client.api.Message<?> message)
StopCursor
shouldStop
in interface StopCursor
public void open(org.apache.pulsar.client.admin.PulsarAdmin admin, TopicPartition partition)
StopCursor
open
in interface StopCursor
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.