Search *

43 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

12825 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

1331 308
apache/incubator-streampark

StreamPark, Make stream processing easier! easy-to-use streaming application development framework and operation platform

Scala versions: 2.12 2.11

development-framework operation-platform streaming etl-pipeline apache easy-to-use streampark

3527 121
apache/incubator-pekko

Build highly concurrent, distributed, and resilient message-driven applications using Java/Scala

Scala versions: 3.x 2.13 2.12

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

799 313
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

533 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

320 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
neotypes/neotypes

Scala lightweight, type-safe, asynchronous driver for neo4j

Scala versions: 3.x 2.13 2.12

database scala functional-programming streaming graph neo4j

154 11
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
apache/incubator-pekko-http

The Streaming-first HTTP server/module of Apache Pekko

Scala versions: 3.x 2.13 2.12

pekko-http streaming http-client websocket reactive http-server pekko http2 http

127 310
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 0 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 3