apache-flink - 用 pulsar 和 flink 端到端交付恰好一次

Question

我正在尝试将 flink 与脉冲星一起使用。脉冲星将充当源和汇。我正在为此解决方案寻找一次性交付保证。

我已经阅读了关于使用 kafka 实现 flink 两阶段提交的信息，但我找不到 pulsar 的等价物。 https://flink.apache.org/features/2018/03/01/end-to-end-exactly-once-apache-flink.html

我还查看了 flink 的脉冲星生产者，它不支持完全一次保证。

https://github.com/apache/pulsar/blob/master/pulsar-flink/src/main/java/org/apache/flink/streaming/connectors/pulsar/PulsarProduceMode.java

我将不胜感激有关如何使用 pulsar flink 组合实现端到端精确交付的任何指示。