Overview

The Apache Pekko Connectors project is an open source initiative to implement stream-aware and reactive integration pipelines for Java and Scala. It is built on top of Apache Pekko Streams, and has been designed from the ground up to understand streaming natively and provide a DSL for reactive and stream-oriented programming, with built-in support for backpressure. Apache Pekko Streams is a Reactive Streams and JDK 9+ java.util.concurrent.Flow-compliant implementation and therefore fully interoperable with other implementations.

If you’d like to know what integrations with Apache Pekko Connectors look like, have a look at our self-contained examples section.

There are a few blog posts and presentations about Apache Pekko Connectors out there, we’ve collected some.

Versions

The code in this documentation is compiled against:

See Apache Pekko Connectors versioning for more details.

Release notes are found at Release Notes.

If you want to try out a connector that has not yet been released, give snapshots a spin which are published after every merged PR.

Contributing

Please feel free to contribute to Apache Pekko Connectors by reporting issues you identify, or by suggesting changes to the code. Please refer to our contributing instructions and our contributor advice to learn how it can be done. The target structure for Apache Pekko Connectors connectors is illustrated by the Reference connector.

We want Apache Pekko and Apache Pekko Connectors to strive in a welcoming and open atmosphere and expect all contributors to respect our code of conduct.

Feel free to tag your project with pekko-connectors keyword in Scaladex for easier discoverability.

1.0.2