我想把flink和pulsar一起用。脉冲星将作为一个源和汇。我正在为这个解决方案寻找一次交货保证。
我读过关于用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
我会很感激任何关于如何实现端到端准确一次与脉冲星Flink组合交付指针。