Reactive Streams API for Apache Kafka
A cohesive & pragmatic framework of FP centric Scala libraries
A library that provides an in-memory Kafka instance to run your ScalaTest specs against.
Write your Spark data to Kafka seamlessly
Kafka-based message queue
Repository for advanced unit-testing with embedded kafka services
Euphoria is an open source Java API for creating unified big-data processing flows. It provides an engine independent programming model which can express both batch and stream transformations.
A Gatling stress test plugin for Apache Kafka 0.8 protocol
Big Data Toolkit for the JVM
Kafka client for functional streams for scala (fs2)
Scala library for Reactive streaming Microservices, CQRS, Event Sourcing, Event Logging, & message-driven apps.
Scala helper modules for operating the Apache Kafka client library (0.9.x - 0.10.x)
Scala Library for Unit-Testing Processing Topologies in Apache Kafka / Kafka Streams
A SQL-like language for performing ETL transformations.