Apache NiFi 连接器

    注意这些连接器目前还没有包含在二进制发行版中。添加依赖、打包配置以及集群运行的相关信息请参考 这里。

    安装 Apache NiFi

    安装 Apache NiFi 集群请参考 这里。

    Apache NiFi Source

    该连接器提供了一个 Source 可以用来从 Apache NiFi 读取数据到 Apache Flink。

    • NiFiSource(SiteToSiteConfig config, long waitTimeMs) - 构造一个 ，需要指定参数 SiteToSiteConfig 和等待时间（单位为毫秒）。

    示例:

    Apache NiFi Sink

    该连接器提供了一个 Sink 可以用来把 Apache Flink 的数据写入到 Apache NiFi。

    NiFiSink(…) 类只有一个构造方法。

    示例: