Akka Streams Kafka

Akka Streams Kafka, also known as Reactive Kafka, is an Akka Streams connector for Apache Kafka.

The examples in this documentation use

• Akka Streams Kafka 0.18 (Github)
• Scala 2.11
• Akka Streams 2.5.7 (Github)
• Apache Kafka 0.11.0.1 (Apache Git)

Dependencies

sbt

libraryDependencies += "com.typesafe.akka" %% "akka-stream-kafka" % "0.18"

Maven

<dependency>
  <groupId>com.typesafe.akka</groupId>
  <artifactId>akka-stream-kafka_2.11</artifactId>
  <version>0.18</version>
</dependency>

Gradle

dependencies {
  compile group: "com.typesafe.akka", name: "akka-stream-kafka_2.11", version: "0.18"
}

scaladsl and javadsl

There are two separate packages named akka.kafka.scaladsl and akka.kafka.javadsl with the API for Scala and Java. These packages contain Producer and Consumer classes with factory methods for the various Akka Streams Flow, Sink and Source that are producing or consuming messages to/from Kafka.