[FLINK-27699][python][connector/pulsar] Support StopCursor.at_publish_time
authorAda Wang <wang4luning@gmail.com>
Thu, 19 May 2022 12:02:34 +0000 (20:02 +0800)
committerDian Fu <dianfu@apache.org>
Sat, 21 May 2022 15:18:28 +0000 (23:18 +0800)
commit18a967f8ad7b22c2942e227fb84f08f552660b5a
tree5386aeb314931832157ca26f41d30faee362d232
parente7d004d81c01a19e7d0d9736b6e9638404324e08
[FLINK-27699][python][connector/pulsar] Support StopCursor.at_publish_time

This closes #19771.
flink-python/pyflink/datastream/connectors/pulsar.py
flink-python/pyflink/datastream/tests/test_connectors.py