pulsar flink:使用Apache Pulsar和Apache Flink进行弹性数据处理 源码

脉冲星Flink连接器 Pulsar Flink连接器使用和实现弹性数据处理。 有关中文文档的详细信息,请参见。 先决条件 Java 8或更高版本 Flink 1.9.0或更高版本 Pulsar 2.4.0或更高版本 基本信息 本节介绍有关Pulsar Flink连接器的基本信息。 客户 当前,支持以下Flink版本。 Flink :它们维护在。 Flink 1.11:它在维护。 Flink 1.12:它在维护。 注意由于Flink的API发生了很大变化,因此我们主要致力于master分支中的新功能,并修复其他分支中的错误。 JAR包位于。 对于使用SBT,Maven或Grad