Mirror of Apache Kafka
Alpakka Kafka connector - Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.
A cohesive & pragmatic framework of FP centric Scala libraries
Scala helper modules for operating the Apache Kafka client library (0.9.x - 1.0.x)
A library that provides an in-memory Kafka instance to run your tests against.
Scala DSL for Unit-Testing Processing Topologies in Kafka Streams
Kafka-based message queue
Thin Scala wrapper around Kafka Streams Java API
Extended datasource implementation for Spark/Hadoop on Aliyun E-MapReduce.
Big Data Toolkit for the JVM
Write your Spark data to Kafka seamlessly
Avro SerDe for Apache Spark structured APIs.
Kafka client for functional streams for scala (fs2)
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.
Functional programming with Kafka and Scala
Library offering http based query on top of Kafka Streams Interactive Queries
Manage your Kafka ACL at Scale
A Gatling stress test plugin for Apache Kafka 0.8 protocol
Kafka-Connect SMT (Single Message Transformations) with SQL syntax (Using Apache Calcite for the SQL parsing)
Plugin for support Kafka in Gatling