Search *

35 results

akka/akka

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

Scala versions: 3.x 2.13 2.12 2.11 2.10

hacktoberfest streaming cloud-native concurrency distributed-systems distributed-actors actor-model akka reactive high-performance

12824 307 309
spotify/scio

A Scala API for Apache Beam and Google Cloud Dataflow.

Scala versions: 2.13 2.12 2.11 2.10

data bigquery dataflow beam scala google-cloud streaming scio batch ml

2496 144
akka/akka-http

The Streaming-first HTTP server/module of Akka

Scala versions: 3.x 2.13 2.12 2.11

hacktoberfest streaming websocket reactive http-server akka-http http2 http http-client akka

1330 308
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

decisioning streaming decision-making low-code big-data automation flink kafka stream-processing scala real-time data-streaming gui decision-engine apache-flink flink-kafka rules-engine lowcode touk

532 881 59
profunktor/redis4cats

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

Scala versions: 3.x 2.13 2.12

cats-effect redis fs2 effects streaming stream client lettuce scala

319 49
akka/akka-grpc

Akka gRPC

Scala versions: 3.x 2.13 2.12 2.11

sbt plugins: 1.0

grpc hacktoberfest streaming akka reactive-streams reactive java akka-http scala rpc

425 79
fd4s/fs2-kafka

Functional Kafka Streams for Scala

Scala versions: 3.x 2.13 2.12 2.11

fs2 kafka-client scala streaming

280 32
azure/azure-event-hubs-spark

Enabling Continuous Data Processing with Apache Spark and Azure Event Hubs

Scala versions: 2.12 2.11 2.10

apache-spark streaming azure eventhubs kafka stream scala real-time microsoft spark-streaming bigdata continuous databricks structured-streaming spark apache ingestion connector event-hubs

228 37
travisbrown/iteratee

Iteratees for Cats

Scala versions: 3.x 2.13 2.12 2.11 2.10

Scala.js versions: 1.x 0.6

streaming scala iteratee resource-management cats

184 24
profunktor/fs2-rabbit

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

Scala versions: 3.x 2.13 2.12 2.11

rabbitmq rabbitmq-client stream fs2 streaming amqp amqp-client

143 31
microsoft/mobius

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

Scala versions: 2.11 2.10

bigdata apache-spark streaming mapreduce dataframe eventhubs kafka-streaming rdd dstream spark-streaming near-real-time csharp mobius spark dataset fsharp

940 37
ottogroup/flink-spector

Framework for Apache Flink unit tests

Scala versions: 2.12 2.11 2.10

apache-flink flink streaming unit-testing

206 10
sloshy/fs2-es

Event sourcing utilities for FS2

Scala versions: 2.13 2.12

Scala.js versions: 1.x

cats-effect event-sourcing scala state-machine events state-management fs2 streaming

79 2
spinoco/fs2-kafka

Kafka client for functional streams for scala (fs2)

Scala versions: 2.12 2.11

fs2-kafka kafka-driver streaming scodec kafka stream-processing scala asynchronous kafka-client

79 3
splink/pagelets

A module for the Play Framework to build highly modular applications

Scala versions: 2.13 2.12 2.11

streaming pagelets big-pipe playframework scala

77 1
spinoco/fs2-mail

asynchronous library for sending and receiving mail via fs2._

Scala versions: 2.12 2.11

smtp imap mime scala asynchronous decoding receive-emails fs2 streaming javamail mail

44 0 3
permutive-engineering/fs2-google-pubsub

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

Scala versions: 3.x 2.13 2.12

cats-effect fp scala google-pubsub fs2 streaming

43 15
absaoss/hyperdrive

Extensible streaming ingestion pipeline on top of Apache Spark

Scala versions: 2.12 2.11

apache-spark streaming spark-structured-streaming framework pipeline kafka streaming-etl spark ingestion

41 8 12
fsanaulla/chronicler-spark

InfluxDB connector to Apache Spark on top of Chronicler

Scala versions: 2.12 2.11

chronicler streaming dataframe spark scala rdd influxdb

27 0 2
zio/zio-ftp

A simple, idiomatic (S)FTP client for ZIO

Scala versions: 3.x 2.13 2.12 2.11

ftp sftp scala connector zio-streams functional-programming streaming streams zio

29 14