Skip to content

jdmaguire/flink-connectors

 
 

Repository files navigation

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.

About

Apache Flink connectors for Pravega.

Resources

License

Stars

Watchers

Forks

Packages

No packages published

Languages

  • Java 100.0%