Build highly concurrent, distributed, and resilient message-driven applications on the JVM
A Scala API for Apache Beam and Google Cloud Dataflow.
The Streaming-first HTTP server/module of Akka
Low-code tool for automating actions on real time data | Stream processing for the users.
:bookmark: Redis client built on top of Cats Effect, Fs2 and Lettuce
Functional Kafka Streams for Scala
Enabling Continuous Data Processing with Apache Spark and Azure Event Hubs
Iteratees for Cats
:rabbit: RabbitMQ stream-based client built on top of Fs2
C# and F# language binding and extensions to Apache Spark
Framework for Apache Flink unit tests
Event sourcing utilities for FS2
Kafka client for functional streams for scala (fs2)
A module for the Play Framework to build highly modular applications
asynchronous library for sending and receiving mail via fs2._
Google Cloud Pub/Sub stream-based client built on top of cats-effect, fs2 and http4s.
Extensible streaming ingestion pipeline on top of Apache Spark
InfluxDB connector to Apache Spark on top of Chronicler
A simple, idiomatic (S)FTP client for ZIO