Skip to content
Eron Wright edited this page Oct 23, 2017 · 18 revisions

Apache Flink Connectors for Pravega

This wiki describes the connectors to read and write Pravega streams with Apache Flink stream processing applications.

Build end-to-end stream processing pipelines that use Pravega as the stream storage and message bus, and Apache Flink for computation over the streams. See the Pravega Concepts page for more information.

See the Table of Contents (right sidebar) for more documentation.

System Requirements

Java 8 or greater is required.

The connectors currently require Apache Flink version 1.3 or newer. The latest release of these connectors are linked against Flink release 1.3.1, which should be compatible with all Flink 1.3.x versions.

Releases

At this time, the master branch is aligned with Pravega 0.1.x. For compatibility with Pravega 0.2.x, use the dev-0.2 branch.