Skip to content

Latest commit

 

History

History
17 lines (9 loc) · 799 Bytes

README.md

File metadata and controls

17 lines (9 loc) · 799 Bytes

Pravega Flink Connectors

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.

Features & Highlights

  • 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

Documentation

See the Project Wiki for documentation on how to build and use the Flink Connector library.