akka/akka

Build highly concurrent, distributed, and resilient message-driven applications on the JVM

spotify/scio

A Scala API for Apache Beam and Google Cloud Dataflow.

akka/akka-http

The Streaming-first HTTP server/module of Akka

akka/akka-grpc

Akka gRPC

profunktor/redis4cats

:bookmark: Redis client built on top of Cats Effect, Fs2 and Lettuce

touk/nussknacker

A visual tool to define and run real-time decision algorithms. Brings agility to business teams, liberates developers to focus on technology.

fd4s/fs2-kafka

Functional Kafka Streams for Scala

azure/azure-event-hubs-spark

Enabling Continuous Data Processing with Apache Spark and Azure Event Hubs

travisbrown/iteratee

Iteratees for Cats

profunktor/fs2-rabbit

:rabbit: RabbitMQ stream-based client built on top of Fs2

microsoft/mobius

C# and F# language binding and extensions to Apache Spark

ottogroup/flink-spector

Framework for Apache Flink unit tests

spinoco/fs2-kafka

Kafka client for functional streams for scala (fs2)

sloshy/fs2-es

Event sourcing utilities for FS2

splink/pagelets

A module for the Play Framework to build highly modular applications

spinoco/fs2-mail

asynchronous library for sending and receiving mail via fs2._

permutive-engineering/fs2-google-pubsub

Google Cloud Pub/Sub stream-based client built on top of cats-effect, fs2 and http4s.

absaoss/hyperdrive

Extensible streaming ingestion pipeline on top of Apache Spark

fsanaulla/chronicler-spark

InfluxDB connector to Apache Spark on top of Chronicler

zio/zio-ftp

A simple, idiomatic (S)FTP client for ZIO