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.
Documentation for version 0.11 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 while the library depends on Akka 2.4.x is fully compatible to be used with Akka 2.5.x. This is because of Akka's strict backwards compatibility guarantees. If you want to use reactive-kafka with Akka 2.5 simply include Akka and Akka Streams dependencies using the latest 2.5 version, for example like this:
libraryDependencies += "com.typesafe.akka" %% "akka-stream" % "2.5.x" // pick the latest version here
libraryDependencies += "com.typesafe.akka" %% "akka-actor" % "2.5.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.
Contributions
Contributions are welcome, see CONTRIBUTING.md