public FlinkPulsarSourceWithoutAdmin<T> setStartFromLatest() {
        this.startupMode = StartupMode.LATEST;
        return this;
    }
Sets the given {@link WatermarkStrategy} on this consumer. These will be used to assign
timestamps to records and generates watermarks to signal event time progress.

<p>Running timestamp extractors / watermark generators directly inside the Pulsar source
(which you can do by using this method), per Pulsar partition, allows users to let them
exploit the per-partition characteristics.

<p>When a subtask of a FlinkTDMQSource reads multiple pulsar partitions,
the streams from the partitions are unioned in a "first come first serve" fashion.
Per-partition characteristics are usually lost that way. For example, if the timestamps are
strictly ascending per Pulsar partition, they will not be strictly ascending in the resulting
Flink DataStream, if the parallel source subtask reads more than one partition.

<p>Common watermark generation patterns can be found as static methods in the
{@link WatermarkStrategy} class.

@return The consumer object, to allow function chaining.
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/internal/FlinkPulsarSourceWithoutAdmin.java