Reactive Streams for Kafka

If you have questions or are working on a pull request or just curious, please feel welcome to join the chat room:

Akka Streams connector for Apache Kafka.

Created and maintained by

Documentation for version 0.18 or later

Documentation and API

Supports Kafka 0.10.x

Documentation for version 0.10 or earlier

The documentation for the old API can be found in OLD_README.md

Supports Kafka 0.9.0.x

Akka versions compatibility

Please note that the library depends on Akka 2.5.x. It can't be used with Akka 2.4.x. Version 0.17 and earlier can be used with Akka 2.4.x.

Note that it is important that all akka-* dependencies are in the same version, so it is recommended to depend on them explicitly to avoid problems with transient dependencies causing an unlucky mix of versions.

See also Akka Compatibility Rules.

Contributions

Contributions are welcome, see CONTRIBUTING.md