pyflink.datastream.connectors.pulsar.StartCursor#
- class StartCursor(_j_start_cursor)[source]#
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()