Page History

...

val kafka_streams_scala_version = "0.1.2"
libraryDependencies ++= Seq("comorg.apache.lightbendkafka" %% "kafka-streams-scala" % kafka_streams_scala_version

...

<dependency>
 <groupId>com<groupId>org.apache.lightbend<kafka</groupId>
 <artifactId>kafka-streams-scala_2.12</artifactId>
 <version>0<version>1.1.2</version>
</dependency>

...

compile 'comorg.apache.lightbendkafka:kafka-streams-scala_2.12:0.1.2'

Dependencies

kafka-streams-scala only depends on the Scala standard library and Kafka Streams 1.0.0.

Sample Usage

The library works by wrapping the original Java abstractions of Kafka Streams within a Scala wrapper object and then using implicit conversions between them. All the Scala abstractions are named with an S appended to the name of the corresponding Java abstraction e.g. StreamBuilderS is a wrapper around StreamBuilder, KStreamS is a wrapper around KStream.

...