-
akka/alpakka-kafka
Alpakka Kafka connector - Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.
Scala versions: 3.x 2.13 2.12 2.11 2.10 -
frees-io/freestyle
A cohesive & pragmatic framework of FP centric Scala libraries
Scala versions: 2.12 2.11Scala.js versions: 0.6 -
touk/nussknacker
Low-code tool for automating actions on real time data | Stream processing for the users.
Scala versions: 2.13 2.12 2.11 -
azure/azure-event-hubs-spark
Enabling Continuous Data Processing with Apache Spark and Azure Event Hubs
Scala versions: 2.12 2.11 2.10 -
absaoss/abris
Avro SerDe for Apache Spark structured APIs.
Scala versions: 2.12 2.11 -
jpzk/mockedstreams
Scala DSL for Unit-Testing Processing Topologies in Kafka Streams
Scala versions: 2.13 2.12 2.11 -
softwaremill/kmq
Kafka-based message queue
Scala versions: 2.13 2.12 2.11 -
aliyun/aliyun-emapreduce-datasources
Extended datasource support for Spark/Hadoop on Aliyun E-MapReduce.
Scala versions: 2.11 2.10 -
banno/kafka4s
Functional programming with Kafka and Scala
Scala versions: 2.13 2.12 -
spinoco/fs2-kafka
Kafka client for functional streams for scala (fs2)
Scala versions: 2.12 2.11 -
mnogu/gatling-kafka
A Gatling stress test plugin for Apache Kafka protocol
Scala versions: 2.12 2.11 -
azhur/kafka-serde-scala
Implicitly converts typeclass encoders to kafka Serializer, Deserializer, Serde.
Scala versions: 3.x 2.13 2.12 2.11