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

上传：handbook31483 浏览： 30 推荐： 0 文件：ZIP 大小：435.71KB 上传时间：2021-02-01 05:58:50 版权申诉

脉冲星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