Pulsar Flink 连接器 2.7.0 支持 Apache Pulsar 2.7.0 和 Apache Flink 1.12 中的功能,并且与 Flink连接器 和Flink 消息格式完全兼容。 新版本特性: 高性能的有序消息队列; 为 Pulsar sink 引入 exactly-once 的语义(基于 Pulsar transaction); 引入 upsert-pulsar 连接器; 支持在 FLIP-27 和 FLIP-95 中引入的新... Pulsar Flinkconnector 2.7.0 正式发布,支持最新版 Pulsar 与 Flink下载地址