pyflink.datastream.connectors.pulsar.StartCursor

class StartCursor(_j_start_cursor)

A factory class for users to specify the start position of a pulsar subscription. Since it would be serialized into split. The implementation for this interface should be well considered. I don’t recommend adding extra internal state for this implementation.

This class would be used only for SubscriptionType.Exclusive and SubscriptionType.Failover.

Methods

default_start_cursor()
earliest()
from_message_id(message_id[, inclusive])	Find the available message id and start consuming from it.
from_publish_time(timestamp)	Seek the start position by using message publish time.
latest()