wawa created FLINK-27653:
----------------------------
Summary: Pulsar Connector bug: The startCursor has been setted
default value of "MessageId.earliest", Every time to restart the job，the
Consumer will do the seek operation.
Key: FLINK-27653
URL: https://issues.apache.org/jira/browse/FLINK-27653
Project: Flink
Issue Type: Bug
Components: API / DataStream
Affects Versions: 1.14.3
Reporter: wawa
Pulsar Connector bug: The startCursor has been setted default value of
'MessageId.earliest', Every time to restart the job，the Consumer will do the
seek operation.
Of course，we can set like this : '.setStartCursor(StartCursor.latest())', then,
when the job restarted, it will do this seek operation :
consumer.seek(MessageId.latest). As a result，some messages will be lost.
What we really want is , the consumer can subscribes from where it stopped.
In general, subscribes from 'earliest' or 'latest', we can use the below
operation instead of seek:
[ConsumerBuilder|https://pulsar.apache.org/api/client/2.9.0-SNAPSHOT/org/apache/pulsar/client/api/ConsumerBuilder.html]<[T|https://pulsar.apache.org/api/client/2.9.0-SNAPSHOT/org/apache/pulsar/client/api/ConsumerBuilder.html]>
subscriptionInitialPosition([SubscriptionInitialPosition
|https://pulsar.apache.org/api/client/2.9.0-SNAPSHOT/org/apache/pulsar/client/api/SubscriptionInitialPosition.html]subscriptionInitialPosition)
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
