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)
Manage your Kafka ACL at Scale
Big Data Toolkit for the JVM
Scala Library for Unit-Testing Processing Topologies in Apache Kafka / Kafka Streams
FS2-derived streaming kafka library
Kafka-Connect SMT (Single Message Transformations) with SQL syntax (Using Apache Calcite for the SQL parsing)
A Gatling stress test plugin for Apache Kafka 0.8 protocol
A tool for continuous end-to-end testing of streaming data applications.
Akka extension to publish and subscribe to Kafka topics
Scala library for Reactive streaming Microservices, CQRS, Event Sourcing, Event Logging, & message-driven apps.
Implicitly converts typeclass encoders to kafka Serializer, Deserializer, Serde.
Repository for advanced unit-testing with embedded kafka services
Write your Spark data to Kafka seamlessly
Kafka-based message queue
Kanadi is a Nakadi client for Scala
Implicit conversion of Encoder and Decoder into Serializer/Deserializer/Serde
Hadoop/Spark on Aliyun, supporting interactions with Aliyun's base services.