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)