GitHub topics: akka-streams

Repositories

mithun644/go-chanstreaming

A lightweight library for building concurrent data processing and streaming pipelines using channels

Language: Go - Size: 34.2 KB - Last synced at: about 11 hours ago - Pushed at: about 12 hours ago - Stars: 0 - Forks: 0

j5ik2o/akka-kinesis

Language: Scala - Size: 597 KB - Last synced at: 4 days ago - Pushed at: 5 days ago - Stars: 9 - Forks: 2

quantori/chem-query-platform

Chemical Query Platform (CQP) is an open-source framework designed for indexing and searching within cheminformatics applications (molecules & reactions)

Language: Java - Size: 755 KB - Last synced at: 5 days ago - Pushed at: 5 days ago - Stars: 1 - Forks: 0

nMoncho/helenus

An Apache Cassandra Client for Scala 2 inspired by Anorm and Quill

Language: Scala - Size: 1.09 MB - Last synced at: 6 days ago - Pushed at: 6 days ago - Stars: 42 - 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.03 MB - Last synced at: 6 days ago - Pushed at: 6 days ago - Stars: 11 - Forks: 4

akka/alpakka-samples

Example projects building Reactive Integrations using Alpakka

Language: Java - Size: 1.2 MB - Last synced at: 8 days ago - Pushed at: 8 days ago - Stars: 68 - Forks: 37

MAIF/otoroshi

Lightweight api management on top of a modern http reverse proxy

Language: Scala - Size: 380 MB - Last synced at: 8 days ago - Pushed at: 8 days ago - Stars: 266 - Forks: 41

position-pal/chat-service

PositionPal chat service

Language: Scala - Size: 4.46 MB - Last synced at: 8 days ago - Pushed at: 8 days ago - Stars: 0 - Forks: 1

akkadotnet/Alpakka

Akka Streams Connectors - Alpakka

Language: C# - Size: 1.24 MB - Last synced at: 3 days ago - Pushed at: 8 days ago - Stars: 110 - Forks: 38

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.5 MB - Last synced at: 12 days ago - Pushed at: 12 days ago - Stars: 33 - Forks: 12

diemenator/go-chanstreaming

A lightweight library for building concurrent data processing and streaming pipelines using channels

Language: Go - Size: 85 KB - Last synced at: 7 days ago - Pushed at: 7 days ago - Stars: 1 - Forks: 0

CleverCloud/pulsar4s

Idiomatic, typesafe, and reactive Scala client for Apache Pulsar

Language: Scala - Size: 821 KB - Last synced at: 15 days ago - Pushed at: 15 days ago - Stars: 230 - Forks: 44

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.48 MB - Last synced at: 13 days ago - Pushed at: 21 days ago - Stars: 1,416 - Forks: 384

akkadotnet/Akka.Streams.Kafka

Kafka Akka.Streams connectors - part of the Alpakka project

Language: C# - Size: 913 KB - Last synced at: 22 days ago - Pushed at: about 2 months ago - Stars: 70 - Forks: 21

paypal/squbs

Akka Streams & Akka HTTP for Large-Scale Production Deployments

Language: Scala - Size: 7.54 MB - Last synced at: 29 days ago - Pushed at: about 1 year ago - Stars: 1,435 - Forks: 238

nMoncho/helenus3

An Apache Cassandra Client for Scala 3 inspired by Anorm and Quill

Language: Scala - Size: 338 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 12 - Forks: 1

mvillafuertem/scala

🤓 Examples Advanced 🧐 Projects Akka 🚀 ZIO ⚡️ Algorithms 😼 Cats

Language: Scala - Size: 32.9 MB - Last synced at: about 1 month ago - Pushed at: 8 months ago - Stars: 9 - Forks: 2

MAIF/thoth

Event sourcing in java with vavr, akka stream and vertx reactive PG driver

Language: Java - Size: 2.2 MB - Last synced at: about 1 month ago - Pushed at: 2 months ago - Stars: 32 - Forks: 9

mjakubowski84/parquet4s

Read and write Parquet in Scala. Use Scala classes as schema. No need to start a cluster.

Language: Scala - Size: 2.37 MB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 285 - Forks: 67

SpongePowered/SystemOfADownload

Downloads webpage builder, backend builds the database and pages

Language: Java - Size: 1.63 MB - Last synced at: 18 days ago - Pushed at: 18 days ago - Stars: 6 - Forks: 3

Karasiq/proxychain

Proxy-chaining SOCKS/HTTP proxy server

Language: Scala - Size: 143 KB - Last synced at: about 1 month ago - Pushed at: over 6 years ago - Stars: 19 - Forks: 6

MattSzm/ProgrammingReactiveSystemsCourse

📚

Language: Scala - Size: 35.2 KB - Last synced at: 4 months ago - Pushed at: 4 months ago - Stars: 0 - Forks: 0

krasserm/akka-stream-eventsourcing

Event sourcing for Akka Streams

Language: Scala - Size: 58.6 KB - Last synced at: 13 days ago - Pushed at: over 7 years ago - Stars: 100 - Forks: 16

Clivern/ActorModel

Actor Pattern Using Akka

Language: Java - Size: 109 KB - Last synced at: 4 days ago - Pushed at: about 1 month ago - Stars: 1 - Forks: 1

Karasiq/torrentstream

BitTorrent streaming engine, written in Scala and based on akka-streams

Language: Scala - Size: 475 KB - Last synced at: about 1 month ago - Pushed at: almost 7 years ago - Stars: 24 - Forks: 5

reugn/aerospike-client-scala

Idiomatic and reactive Scala client for Aerospike database

Language: Scala - Size: 89.8 KB - Last synced at: 28 days ago - Pushed at: 5 months ago - Stars: 10 - Forks: 5

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: 5 days ago - Pushed at: 8 months ago - Stars: 175 - Forks: 25

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: 5 months ago - Pushed at: 5 months ago - Stars: 16 - Forks: 9

stanikol/olx

Web crawler / web scraper micro-service for downloading advertisements from http://olx.ua

Language: Scala - Size: 9.32 MB - Last synced at: 6 months ago - Pushed at: 6 months ago - Stars: 15 - Forks: 1

calvinlfer/websockets-pubsub-akka

WebSockets and Publish-Subscribe with Akka

Language: Scala - Size: 5.86 KB - Last synced at: 4 days ago - Pushed at: over 7 years ago - Stars: 23 - Forks: 1

mikolak-net/travesty

Diagram- and graph-generating library for Akka Streams

Language: Scala - Size: 139 KB - Last synced at: about 1 month ago - Pushed at: about 4 years ago - Stars: 95 - Forks: 7

Rizwanishere/Akka

Contains learnings of how to write concurrent and resilient applications using Akka.

Language: Scala - Size: 75.2 KB - Last synced at: 19 days ago - Pushed at: 7 months ago - Stars: 0 - Forks: 0

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: 6 months ago - Pushed at: 6 months ago - Stars: 10 - Forks: 3

upstart-commerce/avataxsdk

Pure Scala non-blocking (and streaming) client for Avatax

Language: Scala - Size: 812 KB - Last synced at: 9 months ago - Pushed at: 9 months ago - Stars: 0 - Forks: 3

adrian83/robome

Simple CRUD application written with: Java (Akka Streams, Akka Http) and JavaScript (React). Apache Cassandra is used as main data storage.

Language: Java - Size: 4.56 MB - Last synced at: 9 months ago - Pushed at: 9 months ago - Stars: 3 - Forks: 0

zalando-nakadi/kanadi

Kanadi is a Nakadi client for Scala

Language: Scala - Size: 407 KB - Last synced at: 10 months ago - Pushed at: 10 months ago - Stars: 29 - Forks: 20

pwliwanow/foundationdb4s

Type-safe and idiomatic Scala client for FoundationDB

Language: Scala - Size: 207 KB - Last synced at: 20 days ago - Pushed at: 9 months ago - Stars: 28 - Forks: 5

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: 4 days ago - Pushed at: over 7 years ago - Stars: 73 - Forks: 20

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: 6 days ago - Pushed at: about 6 years ago - Stars: 8 - Forks: 11

j-tag/kafka-alpakka-sample

This repository is a sample of using Akka Alpakka extension with Kafka broker to produce and consume data with handling back-pressure.

Language: Scala - Size: 1.53 MB - Last synced at: 10 months ago - Pushed at: 10 months ago - Stars: 1 - Forks: 0

shubhangdutta96/management-service

Management Service is a task manager built with Scala and Akka HTTP, providing APIs for task and user management. It features RESTful APIs, leveraging Slick for database interactions and Flyway for migrations. The project includes clear documentation and setup instructions for seamless integration.

Language: Scala - Size: 54.7 KB - Last synced at: 3 months ago - Pushed at: 11 months ago - Stars: 0 - Forks: 0

ArdavanKhalij/NPM-Package-extraction-with-keyword-differences

This project is the first assignment of software architecture in Vrije Universiteit Brussel, and it is under the supervision of Dr. Coen De Roover, Mr. Camilo Velazquez, and Mr. Ahmed Zerouali.

Language: Scala - Size: 27.3 KB - Last synced at: 11 months ago - Pushed at: 11 months ago - Stars: 3 - Forks: 0

janstenpickle/otters

Streaming cats

Language: Scala - Size: 161 KB - Last synced at: about 1 month ago - Pushed at: over 6 years ago - Stars: 4 - Forks: 1

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: about 1 month ago - Pushed at: over 7 years ago - Stars: 28 - Forks: 2

astukalo/measures

Akka streams demo app for processing of a measurements from a file and writing them to other files

Language: Java - Size: 69.3 KB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 0 - Forks: 0

IgorIvkin/akka-streams-mongodb

Demo application that uses Akka Streams Flow to store data to MongoDB

Language: Java - Size: 64.5 KB - Last synced at: about 1 year ago - Pushed at: about 4 years ago - Stars: 2 - Forks: 0

AbedHadri/log-consumer

An example kafka log consumer using Alp-Akka and Akka Streams

Language: Scala - Size: 7.81 KB - Last synced at: about 1 year ago - Pushed at: over 5 years ago - Stars: 1 - Forks: 0

michalzeman/laPlatform

BigData concept for Lambda Architecture design pattern, Apache Kafka -> for streaming/data pipeline integration, Apache Spark -> for distributed data processing, RESTful, services -> Akka HTTP

Language: Scala - Size: 261 KB - Last synced at: about 1 year ago - Pushed at: about 4 years ago - Stars: 3 - Forks: 0

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: about 1 year ago - Pushed at: over 2 years ago - Stars: 6 - Forks: 2

NeoflexConsulting/fluminous

Scala-based serverless workflow.

Language: Scala - Size: 766 KB - Last synced at: about 1 year ago - Pushed at: over 3 years ago - Stars: 2 - Forks: 0

nilsga/twitter-hbc-akka-stream-source

Akka Stream source stage for Twitter Hosebird Client

Language: Scala - Size: 5.86 KB - Last synced at: about 1 year ago - Pushed at: over 7 years ago - Stars: 2 - Forks: 0

jeroenr/gnip-consumer

Consuming Gnip streaming API using Akka HTTP / Streams 2.4.2

Language: Scala - Size: 1.01 MB - Last synced at: about 1 year ago - Pushed at: about 9 years ago - Stars: 5 - Forks: 1

jeroenr/cloudflow-rain-radar

A sample Cloudflow project. See corresponding blog post:

Language: Scala - Size: 21.5 KB - Last synced at: about 1 year ago - Pushed at: over 5 years ago - Stars: 3 - Forks: 2

divanvisagie/todo-websockets

Websocket example in scala

Language: HTML - Size: 43 KB - Last synced at: about 1 year ago - Pushed at: almost 8 years ago - Stars: 0 - 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: about 1 year ago - Pushed at: almost 6 years ago - Stars: 7 - Forks: 1

takezoe/akka-stream-elasticsearch 📦

Elasticsearch connector for Akka Stream

Language: Scala - Size: 40 KB - Last synced at: about 1 year ago - Pushed at: about 7 years ago - Stars: 10 - Forks: 2

kpmeen/clammyscan

[MIRROR] A Playframework BodyParser for scanning multipart file uploads with ClamAV

Language: Scala - Size: 4.46 MB - Last synced at: about 1 year ago - Pushed at: about 4 years ago - Stars: 9 - Forks: 5

techmonad/learning-akka-stream

Language: Scala - Size: 6.84 KB - Last synced at: about 1 year ago - Pushed at: over 3 years ago - Stars: 0 - Forks: 1

techmonad/akka-http-crud-api

RESTful CRUD API using AkkaHTTP

Language: Scala - Size: 5.86 KB - Last synced at: about 1 year ago - Pushed at: over 7 years ago - Stars: 1 - Forks: 0

Eruimdas/akka-project

An Akka test project which contains Akka-http, Akka Streams, Akka-actors and a docker kafka server.

Language: Scala - Size: 75.2 KB - Last synced at: about 1 year ago - Pushed at: almost 6 years ago - Stars: 0 - Forks: 1

akka/akka-stream-contrib

Add-ons to Akka Stream

Language: Scala - Size: 315 KB - Last synced at: about 1 year ago - Pushed at: almost 2 years ago - Stars: 172 - Forks: 77

BijanVan/play-scala-websocket-demo

play-scala-websocket-demo

Language: Scala - Size: 16.6 KB - Last synced at: about 1 year ago - Pushed at: over 7 years ago - Stars: 0 - Forks: 0

BijanVan/akka-csv-stream

Scala version of "Introduction to Reactive Streams for Java Developers"

Language: Scala - Size: 2.23 MB - Last synced at: about 1 year ago - Pushed at: over 7 years ago - Stars: 6 - Forks: 0

fagossa/alpakka_folder_source

Example using alpakka to read from a directory

Language: Scala - Size: 6.84 KB - Last synced at: about 1 year ago - Pushed at: over 7 years ago - Stars: 0 - Forks: 0

reactive-systems-hamburg/docs

Shared documents for Reactive Systems Hamburg

Size: 14.6 KB - Last synced at: about 1 year ago - Pushed at: about 7 years ago - Stars: 4 - Forks: 2

vicaba/load-profile-generator

Load profile generator for electrical appliances using akka-streams. I mentored this project.

Language: Java - Size: 364 KB - Last synced at: about 1 year ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0

VlasShatokhin/reactive-kafka-streams

Language: Scala - Size: 6.84 KB - Last synced at: about 1 year ago - Pushed at: almost 8 years ago - Stars: 0 - Forks: 0

VlasShatokhin/reactive-community-1

Code used for "Demystification of Reactive Streams" talk on Mar 28th 2017

Language: Scala - Size: 2.74 MB - Last synced at: about 1 year ago - Pushed at: about 8 years ago - Stars: 0 - Forks: 0

VlasShatokhin/it-wknd-streams

Language: Scala - Size: 10.7 KB - Last synced at: about 1 year ago - Pushed at: almost 8 years ago - Stars: 0 - Forks: 0

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: about 1 month ago - Pushed at: about 1 year ago - Stars: 10 - Forks: 7

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: about 1 month ago - Pushed at: about 8 years ago - Stars: 8 - Forks: 2

becompany/akka-social-stream

Language: Scala - Size: 538 KB - Last synced at: over 1 year ago - Pushed at: about 6 years ago - Stars: 4 - Forks: 0

Azure/toketi-iothubreact 📦

Akka Stream library for Azure IoT Hub

Language: Scala - Size: 1.55 MB - Last synced at: 2 months ago - Pushed at: almost 5 years ago - Stars: 39 - Forks: 21

Related Keywords

akka-streams 343 scala 188 akka 174 akka-http 105 kafka 46 reactive-streams 42 akka-actors 38 alpakka 26 reactive 19 akka-persistence 18 java 16 akka-cluster 14 websockets 13 cassandra 13 docker 13 websocket 12 reactive-programming 11 play-framework 11 streaming 10 slick 10 postgresql 10 apache-kafka 9 playframework 8 circe 8 aws 8 spark 8 kafka-streams 8 cats 7 avro 7 sbt 7 mongodb 7 microservices 6 microservice 6 functional-programming 6 event-sourcing 6 example 6 crawler 6 stream-processing 5 graphql 5 akka-streams-connectors 5 akka-stream 5 proxy 5 streams 5 async 5 elasticsearch 5 flink 5 pubsub 5 csv-files 4 hacktoberfest 4 zio 4 reactjs 4 iot 4 akka-typed 4 fs2 4 spark-streaming 4 grpc 4 dicom 4 backpressure 4 kamon-akka 4 reactor 4 mqtt 4 rabbitmq 4 kubernetes 4 kamon 4 youtube 3 model-serving 3 parallel 3 cqrs 3 sqs 3 hadoop 3 docker-compose 3 gzipped-files 3 actors 3 http-proxy 3 redis 3 akka-cluster-sharding 3 chat 3 postgres 3 azure 3 learning 3 workshop 3 react 3 gradle 3 demo 3 giter8 3 json 3 sbt-native-packager 3 pekko-streams 3 monix 3 database 3 spring-boot 3 spray-json 3 protocol-buffers 2 data 2 blog 2 stream 2 shapeless 2 foundationdb 2 simulation 2 etl 2