Topic: "akka-streams"
paypal/squbs
Akka Streams & Akka HTTP for Large-Scale Production Deployments
Language: Scala - Size: 7.54 MB - Last synced at: 2 months ago - Pushed at: over 1 year ago - Stars: 1,434 - Forks: 238
akka/alpakka-kafka
Alpakka Kafka connector - Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.
Language: Scala - Size: 4.6 MB - Last synced at: about 18 hours ago - Pushed at: about 21 hours ago - Stars: 1,415 - Forks: 382
mjakubowski84/parquet4s
Read and write Parquet in Scala. Use Scala classes as schema. No need to start a cluster.
Language: Scala - Size: 2.47 MB - Last synced at: 19 days ago - Pushed at: 19 days ago - Stars: 291 - Forks: 68
MAIF/otoroshi
Lightweight api management on top of a modern http reverse proxy
Language: Scala - Size: 360 MB - Last synced at: 7 days ago - Pushed at: 7 days ago - Stars: 282 - Forks: 44
CleverCloud/pulsar4s
Idiomatic, typesafe, and reactive Scala client for Apache Pulsar
Language: Scala - Size: 856 KB - Last synced at: 8 days ago - Pushed at: 2 months ago - Stars: 230 - Forks: 45
SAFE-Stack/SAFE-Chat 📦
IRC-style chat demo featuring full-stack F#, Akka.Streams, Akkling, Fable, Elmish, Websockets and .NET Core
Language: F# - Size: 13.1 MB - Last synced at: 3 months ago - Pushed at: 11 months ago - Stars: 175 - Forks: 25
akka/akka-stream-contrib
Add-ons to Akka Stream
Language: Scala - Size: 315 KB - Last synced at: about 1 month ago - Pushed at: almost 2 years ago - Stars: 173 - Forks: 78
akkadotnet/Alpakka
Akka Streams Connectors - Alpakka
Language: C# - Size: 1.23 MB - Last synced at: about 6 hours ago - Pushed at: 9 days ago - Stars: 110 - Forks: 38
krasserm/akka-stream-eventsourcing
Event sourcing for Akka Streams
Language: Scala - Size: 58.6 KB - Last synced at: 2 days ago - Pushed at: almost 8 years ago - Stars: 100 - Forks: 16
mikolak-net/travesty
Diagram- and graph-generating library for Akka Streams
Language: Scala - Size: 139 KB - Last synced at: about 2 months ago - Pushed at: about 4 years ago - Stars: 95 - Forks: 7
Stratio/khermes 📦
A distributed fake data generator based in Akka.
Language: Scala - Size: 1.2 MB - Last synced at: almost 2 years ago - Pushed at: over 5 years ago - Stars: 92 - Forks: 32
rucek/akka-streams-in-practice
Import data from CSV files to Cassandra using Akka Streams
Language: Scala - Size: 84 KB - Last synced at: over 2 years ago - Pushed at: over 6 years ago - Stars: 88 - Forks: 22
calvinlfer/akka-http-streaming-response-examples
A list of examples that involve streaming with Akka Streams and used together with Akka HTTP
Language: Scala - Size: 41 KB - Last synced at: 1 day ago - Pushed at: almost 8 years ago - Stars: 73 - Forks: 20
akkadotnet/Akka.Streams.Kafka
Kafka Akka.Streams connectors - part of the Alpakka project
Language: C# - Size: 924 KB - Last synced at: 18 days ago - Pushed at: about 2 months ago - Stars: 71 - Forks: 21
lightbend/model-serving-tutorial 📦
Code and presentation for Strata Model Serving tutorial
Language: Scala - Size: 69.9 MB - Last synced at: almost 2 years ago - Pushed at: almost 6 years ago - Stars: 70 - Forks: 30
akka/alpakka-samples
Example projects building Reactive Integrations using Alpakka
Language: Java - Size: 1.2 MB - Last synced at: about 1 month ago - Pushed at: 3 months ago - Stars: 68 - Forks: 37
reactive-hub/akka-stream-apns
Reactive Streams for APNs
Language: Scala - Size: 105 KB - Last synced at: over 2 years ago - Pushed at: over 8 years ago - Stars: 49 - Forks: 9
typesafehub/fdp-modelserver
An umbrella project for multiple implementations of model serving
Language: Scala - Size: 163 KB - Last synced at: over 1 year ago - Pushed at: almost 8 years ago - Stars: 46 - Forks: 20
itkpi/trembita
Model complex data transformation pipelines easily
Language: Scala - Size: 2.6 MB - Last synced at: over 2 years ago - Pushed at: almost 3 years ago - Stars: 45 - Forks: 2
nMoncho/helenus
An Apache Cassandra Client for Scala 2 inspired by Anorm and Quill
Language: Scala - Size: 1.2 MB - Last synced at: 14 days ago - Pushed at: 14 days ago - Stars: 42 - Forks: 1
Azure/toketi-iothubreact 📦
Akka Stream library for Azure IoT Hub
Language: Scala - Size: 1.55 MB - Last synced at: 20 days ago - Pushed at: about 5 years ago - Stars: 39 - Forks: 21
yangbajing/fusion-data
反应式 海量数据治理平台
Language: Scala - Size: 2.86 MB - Last synced at: over 1 year ago - Pushed at: almost 5 years ago - Stars: 37 - Forks: 22
MAIF/thoth
Event sourcing in java with vavr, akka stream and vertx reactive PG driver
Language: Java - Size: 2.39 MB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 34 - Forks: 10
pbernet/akka_streams_tutorial
A collection of runnable and self-contained examples inspired by various akka-streams (pekko-streams), Alpakka (Pekko connectors) and akka-http (pekko-http) docs, tutorials and blogs
Language: Scala - Size: 66.6 MB - Last synced at: 7 days ago - Pushed at: 7 days ago - Stars: 33 - Forks: 12
typesafehub/activator-akka-stream-java8
Demonstrate Akka streams in Java8
Language: Java - Size: 66.4 KB - Last synced at: over 1 year ago - Pushed at: almost 8 years ago - Stars: 33 - Forks: 14
mingchuno/etcd4s
Scala etcd client implementing V3 APIs
Language: Scala - Size: 105 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 31 - Forks: 4
yangbajing/akka-cookbook
提供清晰、实用的Akka应用指导
Language: Scala - Size: 2.57 MB - Last synced at: over 1 year ago - Pushed at: over 3 years ago - Stars: 31 - Forks: 1
coreyauger/reactive-gremlin
akka http gremlin 3 websocket connector
Language: Scala - Size: 30.3 KB - Last synced at: 3 months ago - Pushed at: over 6 years ago - Stars: 31 - Forks: 2
zalando-nakadi/kanadi
Kanadi is a Nakadi client for Scala
Language: Scala - Size: 407 KB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 29 - Forks: 20
pwliwanow/foundationdb4s
Type-safe and idiomatic Scala client for FoundationDB
Language: Scala - Size: 207 KB - Last synced at: about 2 months ago - Pushed at: 12 months ago - Stars: 28 - Forks: 5
nikdon/telepooz
Functional Telegram Bot API wrapper for Scala on top of akka, circe, cats, and shapeless
Language: Scala - Size: 416 KB - Last synced at: 4 months ago - Pushed at: almost 8 years ago - Stars: 28 - Forks: 2
souo/biplatform
基于akka-http、akka-cluster、akka-stream 构建的报表工具
Language: Scala - Size: 1.82 MB - Last synced at: over 1 year ago - Pushed at: almost 8 years ago - Stars: 28 - Forks: 11
calvinlfer/akka-streams-interleaving
Akka Streams example of how to interleave Sources with priorities
Language: Scala - Size: 10.7 KB - Last synced at: 1 day ago - Pushed at: about 8 years ago - Stars: 28 - Forks: 1
ReactiveCouchbase/reactivecouchbase-rs-core
New ReactiveCouchbase driver using reactive-streams
Language: Scala - Size: 7.27 MB - Last synced at: 3 months ago - Pushed at: over 7 years ago - Stars: 26 - Forks: 10
Karasiq/torrentstream
BitTorrent streaming engine, written in Scala and based on akka-streams
Language: Scala - Size: 475 KB - Last synced at: 29 days ago - Pushed at: about 7 years ago - Stars: 24 - Forks: 5
DanyMariaLee/scale
Another example of a REST API with Akka HTTP
Language: Scala - Size: 42 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 23 - Forks: 3
calvinlfer/es-cqrs-shopping-cart
A resilient and scalable shopping cart system designed using Event Sourcing (ES) and Command Query Responsibility Segregation (CQRS)
Language: Scala - Size: 105 KB - Last synced at: 1 day ago - Pushed at: over 7 years ago - Stars: 23 - Forks: 3
garyaiki/dendrites
Scala library for Reactive streaming Microservices, CQRS, Event Sourcing, Event Logging, & message-driven apps.
Language: Scala - Size: 7.55 MB - Last synced at: 15 days ago - Pushed at: over 7 years ago - Stars: 23 - Forks: 3
calvinlfer/websockets-pubsub-akka
WebSockets and Publish-Subscribe with Akka
Language: Scala - Size: 5.86 KB - Last synced at: 1 day ago - Pushed at: over 7 years ago - Stars: 23 - Forks: 1
rucek/akka-streams-in-practice-java8
Import data from CSV files to Cassandra using Akka Streams with Java 8
Language: Java - Size: 674 KB - Last synced at: over 2 years ago - Pushed at: about 8 years ago - Stars: 22 - Forks: 1
politrons/Akka
Examples and explanations of how Akka toolkit works
Language: Scala - Size: 350 KB - Last synced at: over 1 year ago - Pushed at: almost 3 years ago - Stars: 21 - Forks: 8
gabfssilva/akka-http-microservice-templates
Templates for akka http microservices
Language: Scala - Size: 109 KB - Last synced at: almost 2 years ago - Pushed at: about 7 years ago - Stars: 21 - Forks: 10
FindHotel/akka-stream-trace 📦
dapper tracing implementation for akka-streams and akka-http using htrace and zipkin
Language: Scala - Size: 22.5 KB - Last synced at: about 2 years ago - Pushed at: almost 8 years ago - Stars: 20 - Forks: 8
tomduhourq/akka-streams-example
Example on Akka Streams with productive cases
Language: Scala - Size: 18.6 KB - Last synced at: over 2 years ago - Pushed at: about 8 years ago - Stars: 20 - Forks: 2
vitorsvieira/akka-http-circe-json-template
Akka HTTP REST API Project Template using Akka HTTP 10.0.4 with Circe 0.7.0 targeting Scala 2.12.x
Language: Scala - Size: 27.3 KB - Last synced at: over 1 year ago - Pushed at: over 8 years ago - Stars: 20 - Forks: 7
rucek/reactive-streams-java9
Language: Java - Size: 1.17 MB - Last synced at: over 2 years ago - Pushed at: over 6 years ago - Stars: 19 - Forks: 5
adamldavis/reactive-streams-in-java
Code for "Reactive Streams in Java" book
Language: Java - Size: 37.1 KB - Last synced at: over 2 years ago - Pushed at: almost 7 years ago - Stars: 19 - Forks: 23
Karasiq/proxychain
Proxy-chaining SOCKS/HTTP proxy server
Language: Scala - Size: 143 KB - Last synced at: 4 months ago - Pushed at: almost 7 years ago - Stars: 19 - Forks: 6
eiennohito/grpc-akka-stream-subrepo
akka-stream server/client bindings for gRPC
Language: Scala - Size: 83 KB - Last synced at: over 2 years ago - Pushed at: over 7 years ago - Stars: 19 - Forks: 3
yannick-cw/elastic-indexer4s
Stream your stuff into elasticsearch
Language: Scala - Size: 157 KB - Last synced at: 4 months ago - Pushed at: 12 months ago - Stars: 18 - Forks: 6
slicebox/slicebox
Microservice for safe sharing and easy access to medical images
Language: Scala - Size: 43.2 MB - Last synced at: over 2 years ago - Pushed at: over 6 years ago - Stars: 18 - Forks: 13
jeroenr/tepkin Fork of fehmicansaglam/tepkin
Reactive MongoDB Driver for Scala
Language: Scala - Size: 1.31 MB - Last synced at: 7 months ago - Pushed at: over 2 years ago - Stars: 17 - Forks: 5
softwaremill/reactive-streams-for-java-developers 📦
Language: Java - Size: 2.28 MB - Last synced at: over 1 year ago - Pushed at: almost 8 years ago - Stars: 17 - Forks: 10
jaspervz/akkastreams-kafka-example
An example project using Akka Streams with Kafka and a Schema Registry to read and write messages in Avro format.
Language: Scala - Size: 6.84 KB - Last synced at: 7 months ago - Pushed at: 7 months ago - Stars: 16 - Forks: 9
coreyauger/typebus
Framework for building distributed microserviceies in scala with akka-streams and kafka
Language: Scala - Size: 829 KB - Last synced at: 4 months ago - Pushed at: over 5 years ago - Stars: 16 - Forks: 3
stanikol/olx
Web crawler / web scraper micro-service for downloading advertisements from http://olx.ua
Language: Scala - Size: 9.32 MB - Last synced at: 8 months ago - Pushed at: 8 months ago - Stars: 15 - Forks: 1
calvinlfer/Kafka-Akka-HTTP-and-Akka-Streams-integration
An example showing how to integrate Apache Kafka with Akka Streams and Akka HTTP.
Language: Scala - Size: 4.88 KB - Last synced at: 1 day ago - Pushed at: almost 9 years ago - Stars: 15 - Forks: 4
pwliwanow/fdb-pubsub
Pub/Sub built on top of FoundationDB
Language: Scala - Size: 71.3 KB - Last synced at: 3 months ago - Pushed at: 12 months ago - Stars: 14 - Forks: 3
burakkose/Quark
Quark is a streaming-first Api Gateway using Akka
Language: Scala - Size: 56.6 KB - Last synced at: almost 2 years ago - Pushed at: almost 8 years ago - Stars: 14 - Forks: 3
CallHandling/freeswitch-scala-esl
A reactive event socket library for FreeSwitch written using Scala and Akka Streams
Language: Scala - Size: 509 KB - Last synced at: 2 months ago - Pushed at: about 1 year ago - Stars: 13 - Forks: 3
phdata/pulse 📦
phData Pulse application log aggregation and monitoring
Language: Scala - Size: 11.4 MB - Last synced at: over 1 year ago - Pushed at: over 5 years ago - Stars: 13 - Forks: 18
calvinlfer/Akka-Streams-custom-stream-processing-examples
Demos of how to do custom stream processing using the Akka Streams GraphStages API
Language: Scala - Size: 21.5 KB - Last synced at: 1 day ago - Pushed at: over 8 years ago - Stars: 13 - Forks: 4
nMoncho/helenus3
An Apache Cassandra Client for Scala 3 inspired by Anorm and Quill
Language: Scala - Size: 360 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 12 - Forks: 1
casefabric/bounded-framework
The Bounded framework for Scala, Akka and Domain Driven Design
Language: Scala - Size: 1.17 MB - Last synced at: 1 day ago - Pushed at: 8 months ago - Stars: 12 - Forks: 3
zhang2014/akka-stream-clickhouse
Analysis of Clickhouse file structure based on akka-stream implementation
Language: Scala - Size: 145 KB - Last synced at: 3 months ago - Pushed at: about 8 years ago - Stars: 12 - Forks: 1
kpmeen/kafka-websocket-proxy
WebSocket proxy that allows clients to produce and consume messages from topics in Apache Kafka. (mirror of https://gitlab.com/kpmeen/kafka-websocket-proxy)
Language: Scala - Size: 2.06 MB - Last synced at: 24 days ago - Pushed at: 24 days ago - Stars: 11 - Forks: 4
sysgears/akka-spark-pipeline
An example project that implements a data pipeline using Scala, Akka, and Spark and works with document-oriented and graph databases to let you find out how frequently a specific technology is used with different technology stacks.
Language: Scala - Size: 130 KB - Last synced at: 4 months ago - Pushed at: almost 6 years ago - Stars: 11 - Forks: 4
reugn/aerospike-client-scala
Idiomatic and reactive Scala client for Aerospike database
Language: Scala - Size: 89.8 KB - Last synced at: 4 months ago - Pushed at: 7 months ago - Stars: 10 - Forks: 5
exini/dicom-streams Fork of slicebox/dicom-streams
A streaming and non-blocking API for reading and processing DICOM data
Language: Scala - Size: 3.59 MB - Last synced at: 9 months ago - Pushed at: 9 months ago - Stars: 10 - Forks: 3
500px/kinesis-stream
Scala based wrapper for Kinesis Consumer Library which exposes the stream as an Akka Streams Source
Language: Scala - Size: 119 KB - Last synced at: 22 days ago - Pushed at: over 1 year ago - Stars: 10 - Forks: 7
Cumulus-Cloud/cumulus
Personal cloud done right!
Language: Scala - Size: 3.1 MB - Last synced at: almost 2 years ago - Pushed at: about 5 years ago - Stars: 10 - Forks: 2
duanebester/streaming-ocr
A look at OCR within Akka Streams
Language: Scala - Size: 5.87 MB - Last synced at: over 1 year ago - Pushed at: over 5 years ago - Stars: 10 - Forks: 4
bszwej/mongodb-s3-stream-example
MongoDB collection backup and restore to/from Amazon S3 using Akka Streams and Alpakka.
Language: Scala - Size: 14.6 KB - Last synced at: over 1 year ago - Pushed at: over 6 years ago - Stars: 10 - Forks: 4
Karasiq/proxyutils
Scala HTTP/SOCKS proxy library, based on akka-streams
Language: Scala - Size: 95.7 KB - Last synced at: 4 months ago - Pushed at: over 6 years ago - Stars: 10 - Forks: 4
takezoe/akka-stream-elasticsearch 📦
Elasticsearch connector for Akka Stream
Language: Scala - Size: 40 KB - Last synced at: over 1 year ago - Pushed at: over 7 years ago - Stars: 10 - Forks: 2
artem0/kafka-scala-api
Samples for using Kafka within Spark Streaming and Akka Actors, Akka Streams
Language: Scala - Size: 46.9 KB - Last synced at: about 2 months ago - Pushed at: almost 8 years ago - Stars: 10 - Forks: 6
j5ik2o/akka-kinesis
Language: Scala - Size: 604 KB - Last synced at: 14 days ago - Pushed at: 27 days ago - Stars: 9 - Forks: 2
mvillafuertem/scala
🤓 Examples Advanced 🧐 Projects Akka 🚀 ZIO ⚡️ Algorithms 😼 Cats
Language: Scala - Size: 32.9 MB - Last synced at: 4 months ago - Pushed at: 10 months ago - Stars: 9 - Forks: 2
kpmeen/clammyscan
[MIRROR] A Playframework BodyParser for scanning multipart file uploads with ClamAV
Language: Scala - Size: 4.46 MB - Last synced at: 23 days ago - Pushed at: over 4 years ago - Stars: 9 - Forks: 5
aleksandarskrbic/akka-data-processing
Comparison of Classic Actors, Akka Streams, and Typed Actors
Language: Scala - Size: 89.8 KB - Last synced at: 4 months ago - Pushed at: about 5 years ago - Stars: 9 - Forks: 3
s12v/akka-stream-sqs
Reactive SQS for Akka streams
Language: Scala - Size: 45.9 KB - Last synced at: 4 months ago - Pushed at: over 6 years ago - Stars: 9 - Forks: 7
rucek/akka-streams-in-practice-kotlin
Import data from CSV files to Cassandra using Akka Streams with Kotlin
Language: Kotlin - Size: 61.5 KB - Last synced at: over 2 years ago - Pushed at: about 8 years ago - Stars: 9 - Forks: 0
andreas-schroeder/akka-http-concurrency-limits
Adaptive concurrency limits for akka http
Language: Scala - Size: 82 KB - Last synced at: about 2 years ago - Pushed at: almost 5 years ago - Stars: 8 - Forks: 0
IBM/db2-event-store-akka-streams 📦
Use Akka to implement a WebSockets endpoint and stream data to Db2 Event Store
Language: Jupyter Notebook - Size: 2.39 MB - Last synced at: about 2 months ago - Pushed at: over 6 years ago - Stars: 8 - Forks: 11
msilb/scalanda-v20
Scala Akka HTTP client for Oanda REST API v20
Language: Scala - Size: 89.8 KB - Last synced at: 5 months ago - Pushed at: over 6 years ago - Stars: 8 - Forks: 6
sanjeevghimire/akka-react-cloudant
A Soccer Dashboard created by scraping EPL website using Akka backend and ReactJS frontend and IBM Cloudant for object storage
Language: CSS - Size: 1.38 MB - Last synced at: over 2 years ago - Pushed at: over 7 years ago - Stars: 8 - Forks: 3
flinters/play-scala-sse-example
An example Play application showing Server Sent Events using Akka Streams in Scala
Language: Scala - Size: 17.6 KB - Last synced at: almost 2 years ago - Pushed at: over 7 years ago - Stars: 8 - Forks: 3
holidaycheck/amqp-akka-streams
A library that allow you to leverage Akka Streams while reading or writing messages to AMQP broker.
Language: Scala - Size: 28.3 KB - Last synced at: 3 months ago - Pushed at: almost 8 years ago - Stars: 8 - Forks: 0
pbugnion/api-scraping-akka-streams
How to build a resilient, long-running API scraper with Akka streams
Language: Scala - Size: 23.4 KB - Last synced at: 4 months ago - Pushed at: over 8 years ago - Stars: 8 - Forks: 2
hanabix/passport
A web gateway for enterprise internal application supports authentication by scaning QR code with APP
Language: Scala - Size: 177 KB - Last synced at: 4 months ago - Pushed at: 4 months ago - Stars: 7 - Forks: 1
pinkstack/mydis
mydis is remote dictionary server, an in-memory data structure with optional durability. Similar to Redis.
Language: Scala - Size: 54.7 KB - Last synced at: over 2 years ago - Pushed at: about 4 years ago - Stars: 7 - Forks: 0
fpaschos/simple-bank-system
Simple implementation of a bank accounting system using akka typed for learning purposes
Language: Scala - Size: 14.6 MB - Last synced at: over 2 years ago - Pushed at: over 5 years ago - Stars: 7 - Forks: 0
jwatelet/buzz-radiant
A Scala and akka.io project whose use flow and graph to listen streams. The goal is be able to do buzz monitoring.
Language: Scala - Size: 130 KB - Last synced at: over 1 year ago - Pushed at: about 6 years ago - Stars: 7 - Forks: 1
SpongePowered/SystemOfADownload
Downloads webpage builder, backend builds the database and pages
Language: Java - Size: 1.65 MB - Last synced at: 27 days ago - Pushed at: 28 days ago - Stars: 6 - Forks: 3
olxbr/aws-sqsd
A simple alternative to the Amazon SQS Daemon ("sqsd") used on AWS Beanstalk worker tier instances, based on https://github.com/mozart-analytics/sqsd
Language: Scala - Size: 15.6 KB - Last synced at: over 1 year ago - Pushed at: over 2 years ago - Stars: 6 - Forks: 2
schrepfler/artemis
Artemis aims to implement the baseline Apollo server WebSocket subscriptions protocol on top of Akka and Sangria
Language: Scala - Size: 274 KB - Last synced at: 4 months ago - Pushed at: over 2 years ago - Stars: 6 - Forks: 3
klpx/akka-streams-postgresql-copy
Postgres COPY operation adapter for Akka Streams
Language: Scala - Size: 63.5 KB - Last synced at: over 1 year ago - Pushed at: almost 4 years ago - Stars: 6 - Forks: 2
Azure/azure-event-hubs-reactive 📦
Akka Reactive Streaming for Azure Event Hubs
Language: Scala - Size: 1.36 MB - Last synced at: over 1 year ago - Pushed at: almost 6 years ago - Stars: 6 - Forks: 5
lightbend/fdp-speculative-model-serving 📦
Experimental implementation of speculative model serving
Language: Scala - Size: 792 KB - Last synced at: over 2 years ago - Pushed at: about 6 years ago - Stars: 6 - Forks: 1
rucek/reactive-integration-with-akka-streams-and-alpakka
Example data processing pipeline with Akka Streams and Alpakka
Language: Java - Size: 58.6 KB - Last synced at: over 2 years ago - Pushed at: over 6 years ago - Stars: 6 - Forks: 2