Introduction

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

Dependencies

sbt

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

Maven

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

Gradle

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

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.