Clojure is a data-oriented langauge that runs on the JVM, a perfect companion for Streaming Compute with Kafka.
This library is designed to demonstrate Kafka Streams with Clojure via the Kafka Streams Testing Framework.
No dependency on a running Kafka cluster, just run:
lein test
Or run the troy-west.kstream.examples
test namespace within a REPL
Curious to see what Clojure and Kafka Streams tests looking like? Here are the goodies!
How about Clojure / Transit specific Serdes? Right over here.
We'll add examples to this library over time, you're welcome to contribute.
Copyright © 2018 Troy-West Pty Ltd.
Distributed under the Eclipse Public License either version 1.0 or (at your option) any later version.