Search *

43 results

akka/akka 2.8.8

A platform to build and run apps that are elastic, agile, and resilient. SDK, libraries, and hosted environments.

Scala versions: 3.x 2.13 2.12

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

13058 254 309
spotify/scio 0.9.6

A Scala API for Apache Beam and Google Cloud Dataflow.

Scala versions: 2.13 2.12

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

2557 149
akka/akka-http 10.5.3

The Streaming-first HTTP server/module of Akka

Scala versions: 3.x 2.13 2.12

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

1337 310
apache/incubator-streampark 2.1.5

Make stream processing easier! Easy-to-use streaming application development framework and operation platform.

Scala versions: 2.12

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

3907 148
apache/pekko 1.1.2

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

1222 456 308
touk/nussknacker 1.17.0

Low-code tool for automating actions on real time data | Stream processing for the users.

Scala versions: 2.13 2.12

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

661 66
profunktor/redis4cats 1.7.1

: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

350 54
akka/akka-grpc 2.3.4

A platform to build and run apps that are elastic, agile, and resilient. SDK, libraries, and hosted environments.

Scala versions: 3.x 2.13 2.12

sbt plugins: 1.x

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

431 81
fd4s/fs2-kafka 3.6.0

Functional Kafka Streams for Scala

Scala versions: 3.x 2.13 2.12

fs2 kafka-client scala streaming

293 38
azure/azure-event-hubs-spark 2.1.5

Enabling Continuous Data Processing with Apache Spark and Azure Event Hubs

Scala versions: 2.11

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

234 37
travisbrown/iteratee 0.20.0

Iteratees for Cats

Scala versions: 3.x 2.13 2.12

Scala.js versions: 1.x

streaming scala iteratee resource-management cats

183 24
neotypes/neotypes 1.2.0

Scala lightweight, type-safe, asynchronous driver for neo4j

Scala versions: 3.x 2.13

database scala functional-programming streaming graph neo4j

165 12
profunktor/fs2-rabbit 5.3.0

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

Scala versions: 3.x 2.13 2.12

rabbitmq rabbitmq-client stream fs2 streaming amqp amqp-client

149 36
apache/pekko-http 1.1.0

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

153 313
microsoft/mobius 2.0.200

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

Scala versions: 2.11

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

941 37
ottogroup/flink-spector 0.9.4

Framework for Apache Flink unit tests

Scala versions: 2.12 2.11

apache-flink flink streaming unit-testing

207 10
sloshy/fs2-es 0.3.0

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

80 2
spinoco/fs2-kafka 0.4.0

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

78 3
splink/pagelets 0.0.11

A module for the Play Framework to build highly modular applications

Scala versions: 2.13 2.12

streaming pagelets big-pipe playframework scala

76 1
permutive-engineering/fs2-pubsub 1.1.0

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

48 18