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.
-
Exactly-once processing guarantees for both reader and writer, supporting end-to-end exactly-once processing pipelines
-
Seamless integration with Flink's checkpoints & savepoints
-
Parallel readers and writers supporting high throughput and low latency processing
See the Project Wiki for documentation on how to build and use the Flink Connector library.