A library that provides an in-memory Kafka instance to run your tests against.
-
Updated
Nov 12, 2019 - Scala
A library that provides an in-memory Kafka instance to run your tests against.
Code samples for the Lightbend tutorial on writing microservices with Akka Streams, Kafka Streams, and Kafka
Thin Scala wrapper around Kafka Streams Java API
Scala DSL for Unit-Testing Processing Topologies in Kafka Streams
A REPL for Apache Kafka
Library offering http based query on top of Kafka Streams Interactive Queries
Examples of Avro, Kafka, Schema Registry, Kafka Streams, Interactive Queries, KSQL, Kafka Connect in Scala
Implicitly converts typeclass encoders to kafka Serializer, Deserializer, Serde.
Twitter Streaming API Example with Kafka Streams in Scala
An umbrella project for multiple implementations of model serving
Demo code from my talk @ Codemotion Milan 2018 - "Building event sourced systems with Kafka Streams"
Oh you know, just a coupla, two, tree Kafka Streams in Scala
Plumber, for your dirtiest Kafka streaming jobs
Implicit conversion of Encoder and Decoder into Serializer/Deserializer/Serde
Simple application implementing Change Data Capture using Kafka Streams.
library for reliable processing records received from kafka
Add a description, image, and links to the kafka-streams topic page so that developers can more easily learn about it.
To associate your repository with the kafka-streams topic, visit your repo's landing page and select "manage topics."