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

Dependencies

sbt
libraryDependencies += "com.typesafe.akka" %% "akka-stream-kafka" % "0.16"
Maven
<dependency>
  <groupId>com.typesafe.akka</groupId>
  <artifactId>akka-stream-kafka_2.11</artifactId>
  <version>0.16</version>
</dependency>
Gradle
dependencies {
  compile group: "com.typesafe.akka", name: "akka-stream-kafka_2.11", version: "0.16"
}

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.

Next: Producer