Apache NiFi Connector

    This connector provides a Source and Sink that can read from and write to Apache NiFi. To use this connector, add the following dependency to your project:

    Copied to clipboard!

    Note that the streaming connectors are currently not part of the binary distribution. See for information about how to package the program with the libraries for cluster execution.

    Installing Apache NiFi

    Instructions for setting up a Apache NiFi cluster can be found .

    Apache NiFi Source

    The connector provides a Source for reading data from Apache NiFi to Apache Flink.

    • NiFiSource(SiteToSiteConfig config, long waitTimeMs) - Constructs a given the client’s SiteToSiteConfig and the specified wait time (in milliseconds).

    Example:

    Java

    Scala

    Apache NiFi Sink

    The connector provides a Sink for writing data from Apache Flink to Apache NiFi.

    The class NiFiSink(…) provides a constructor for instantiating a NiFiSink.

    Example:

    Java

    Scala

    Back to top