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.
Scala helper modules for operating the Apache Kafka client library (0.9.x - 1.0.x)
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
Repository for advanced unit-testing with embedded kafka services
Kafka client for functional streams for scala (fs2)
Write your Spark data to Kafka seamlessly
A SQL-like language for performing ETL transformations.
Akka extension to publish and subscribe to Kafka topics
A Gatling stress test plugin for Apache Kafka 0.8 protocol
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)
A tool for continuous end-to-end testing of streaming data applications.
Library offering http based query on top of Kafka Streams Interactive Queries
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.
Thin Scala wrapper around Kafka Streams Java API
Big Data Toolkit for the JVM