thomasg19930417 commented on PR #103: URL: https://github.com/apache/flink-connector-pulsar/pull/103#issuecomment-2791619064
@yebai1105 If the StartCursor for consumption is set to "earliest", will there be any issues just by changing this part? Looking at the code, there is no other place where the cursor is set except here. It seems that the "subscriptionInitialPosition" needs to be set when creating the consumer in the PulsarPartitionSplitReader. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
