Building a Kafka producer with Akka
According to the definition, Akka is a free and open source toolkit and runtime that simplifies the construction of concurrent and distributed applications for the JVM. There is a big infrastructure for connecting both projects.
In this recipe, a Kafka producer is built with Akka.
Getting ready
The Akka connector is available at Maven Central for Scala 2.11 at the following Maven coordinates:
libraryDependencies += "com.typesafe.akka" %% "akka-stream-kafka" % "0.11-M4"How to do it...
A producer publishes messages to Kafka topics. The message itself contains information about what topic and partition to publish. One can publish to different topics with the same producer. The underlying implementation uses the Kafka producer.
When creating a producer stream, specify the ProducerSettings defining the following:
- Kafka cluster bootstrap server
- Serializers for the keys and values
- Tuning parameters
The imports necessary for ProducerSettings are as follows:
import akka.kafka...
