Quan Limin created FLINK-37299:
----------------------------------

             Summary: flink stateless startup cannot continue consuming from 
the current location of the consumer group
                 Key: FLINK-37299
                 URL: https://issues.apache.org/jira/browse/FLINK-37299
             Project: Flink
          Issue Type: Bug
          Components: Connectors / Pulsar
    Affects Versions: pulsar-4.1.0
            Reporter: Quan Limin


When Flink chooses to start recovery from the position recorded by the Pulsar 
subscription group, it actually starts recovery from the position specified by 
StartCursor.
Setting 'pulsar.source.resetSubscriptionCursor' to true or false has no effect



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to