flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSource.java [145:150]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        return new PulsarSourceEnumerator(
                subscriber,
                startCursor,
                stopCursor,
                rangeGenerator,
                sourceConfiguration,
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSource.java [160:165]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        return new PulsarSourceEnumerator(
                subscriber,
                startCursor,
                stopCursor,
                rangeGenerator,
                sourceConfiguration,
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -