apache/kafka   3.9.0

Mirror of Apache Kafka

akka/alpakka-kafka   4.0.2

Alpakka Kafka connector - Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.

frees-io/freestyle   0.8.2

A cohesive & pragmatic framework of FP centric Scala libraries

touk/nussknacker   1.18.0

Low-code tool for automating actions on real time data | Stream processing for the users.

conduktor/kafka-security-manager   1.0.1

Manage your Kafka ACL at scale

cakesolutions/scala-kafka-client   2.0.0

Scala helper modules for operating the Apache Kafka client library (0.9.x - 2.1.0)

manub/scalatest-embedded-kafka   2.0.0

A library that provides an in-memory Kafka instance to run your tests against.

azure/azure-event-hubs-spark   2.1.5

Enabling Continuous Data Processing with Apache Spark and Azure Event Hubs

absaoss/abris   4.0.0

Avro SerDe for Apache Spark structured APIs.

lightbend/kafka-streams-scala   0.2.1

Thin Scala wrapper around Kafka Streams Java API

jpzk/mockedstreams   3.9.0

Scala DSL for Unit-Testing Processing Topologies in Kafka Streams

softwaremill/kmq   0.3.1

Kafka-based message queue

benfradet/spark-kafka-writer   0.6.0

Write your Spark data to Kafka seamlessly

51zero/eel-sdk   1.2.4

Big Data Toolkit for the JVM

aliyun/aliyun-emapreduce-datasources   2.2.0

Extended datasource support for Spark/Hadoop on Aliyun E-MapReduce.

banno/kafka4s   6.0.1

Functional programming with Kafka and Scala

spinoco/fs2-kafka   0.4.0

Kafka client for functional streams for scala (fs2)

lightbend/kafka-streams-query   0.1.1

Library offering http based query on top of Kafka Streams Interactive Queries

mnogu/gatling-kafka   0.3.1

A Gatling stress test plugin for Apache Kafka protocol

azhur/kafka-serde-scala   0.8.2

Implicitly converts typeclass encoders to kafka Serializer, Deserializer, Serde.