Dian Fu created FLINK-27729: ------------------------------- Summary: Support constructing StartCursor and StopCursor from MessageId Key: FLINK-27729 URL: https://issues.apache.org/jira/browse/FLINK-27729 Project: Flink Issue Type: Improvement Components: API / Python, Connectors / Pulsar Reporter: Dian Fu Fix For: 1.16.0
Currently, StartCursor.fromMessageId and StopCursor.fromMessageId are still not supported in Python pulsar connectors. I think we could leverage the [pulsar Python library|https://pulsar.apache.org/api/python/#pulsar.MessageId] to implement these methods. -- This message was sent by Atlassian Jira (v8.20.7#820007)