Scala helper modules for operating the Apache Kafka client library (0.9.x - 1.0.x)
A SQL-like language for performing ETL transformations.
Akka extension to publish and subscribe to Kafka topics
Kafka client for functional streams for scala (fs2)
Repository for advanced unit-testing with embedded kafka services
Write your Spark data to Kafka seamlessly
Scala library for Reactive streaming Microservices, CQRS, Event Sourcing, Event Logging, & message-driven apps.
Scala Library for Unit-Testing Processing Topologies in Apache Kafka / Kafka Streams
Alpakka Kafka connector - Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.
A library that provides an in-memory Kafka instance to run your ScalaTest specs against.
A Gatling stress test plugin for Apache Kafka 0.8 protocol
Converts typeclass encoders to kafka Serializer, Deserializer, Serde.
Library for building fast, scalable, fault-tolerant Data APIs based on Akka, ZooKeeper and Kafka with Avro in between
Kafka-Connect SMT (Single Message Transformations) with SQL syntax (Using Apache Calcite for the SQL parsing)
Thin Scala wrapper around Kafka Streams Java API
Big Data Toolkit for the JVM
Kafka-based message queue
A tool for continuous end-to-end testing of streaming data applications.