A cohesive & pragmatic framework of FP centric Scala libraries
Reactive Streams API for Apache Kafka
Scala helper modules for operating the Apache Kafka client library (0.9.x - 0.10.x)
A library that provides an in-memory Kafka instance to run your ScalaTest specs against.
Kafka-based message queue
A Scala library of streaming components for building Microservices, Event Sourcing, Event Logging, CQRS, and Reactive systems.
Write your RDDs and DStreams to Kafka seamlessly
A SQL-like query language for performing ETL functions.
Scala Library for Unit-Testing Processing Topologies in Apache Kafka / Kafka Streams
Kafka client for functional streams for scala (fs2)
A Gatling stress test plugin for Apache Kafka 0.8 protocol
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.