A library that provides an in-memory Kafka instance to run your tests against.
Kafka (Streams) extensions/helpers
Implicitly converts typeclass encoders to kafka Serializer, Deserializer, Serde.
Implicit conversion of Encoder and Decoder into Serializer/Deserializer/Serde
Library offering http based query on top of Kafka Streams Interactive Queries
Thin Scala wrapper around Kafka Streams Java API
Scala Library for Unit-Testing Processing Topologies in Apache Kafka / Kafka Streams