A cohesive & pragmatic framework of FP centric Scala libraries
A library that provides an in-memory Kafka instance to run your tests against.
Scala helper modules for operating the Apache Kafka client library (0.9.x - 1.0.x)
Scala Library for Unit-Testing Processing Topologies in Kafka Streams
Kafka (Streams) extensions/helpers
Scala library for Reactive streaming Microservices, CQRS, Event Sourcing, Event Logging, & message-driven apps.
A SQL-like language for performing ETL transformations.
Manage your Kafka ACL at Scale
Repository for advanced unit-testing with embedded kafka services
A Gatling stress test plugin for Apache Kafka 0.8 protocol
Library and a Framework for building fast, scalable, fault-tolerant Data APIs based on Akka, Avro, ZooKeeper and Kafka
Kafka-based message queue
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.
Akka Kafka wrapper to publish and subscribe to Kafka topics
Write your Spark data to Kafka seamlessly
In-memory Kafka Cluster (including ZooKeeper) to run your tests against.
CodeFeedr core infrastructure
Functional programming with Kafka and Scala