Home

Documentation for the Apache Flink connectors for Pravega

These docs describe 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.

Table of Contents

• Creating a streaming project with Flink and Pravega
• Building the connectors from source
• Flink Pravega Reader
• Flink Pravega Writer

Versions

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.