THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||
---|---|---|
| ||
val kafka_streams_scala_version = "0.1.2" libraryDependencies ++= Seq("comorg.apache.lightbendkafka" %% "kafka-streams-scala" % kafka_streams_scala_version |
...
Code Block | ||
---|---|---|
| ||
<dependency> <groupId>com<groupId>org.apache.lightbend<kafka</groupId> <artifactId>kafka-streams-scala_2.12</artifactId> <version>0<version>1.1.2</version> </dependency> |
...
Code Block | ||
---|---|---|
| ||
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
.
...