309 Open source projects that are alternatives of or similar to Akka-Streams-custom-stream-processing-examples

Add-ons to Akka Stream

IRC-style chat demo featuring full-stack F#, Akka.Streams, Akkling, Fable, Elmish, Websockets and .NET Core

Example projects building Reactive Integrations using Alpakka

Alpakka Kafka connector - Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.

A resilient and scalable shopping cart system designed using Event Sourcing (ES) and Command Query Responsibility Segregation (CQRS)

Functional Telegram Bot API wrapper for Scala on top of akka, circe, cats, and shapeless

Lightweight real-time big data streaming engine over Akka

Examples and explanations of how Akka toolkit works

Diagram- and graph-generating library for Akka Streams

Framework for building distributed microserviceies in scala with akka-streams and kafka

Akka Streams & Akka HTTP for Large-Scale Production Deployments

Akka Stream library for Azure IoT Hub

Akka Streams example of how to interleave Sources with priorities

Quark is a streaming-first Api Gateway using Akka

Lightweight api management on top of a modern http reverse proxy

提供清晰、实用的Akka应用指导

Akka HTTP REST API Project Template using Akka HTTP 10.0.4 with Circe 0.7.0 targeting Scala 2.12.x

Another example of a REST API with Akka HTTP

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

Microservice for safe sharing and easy access to medical images

A distributed fake data generator based in Akka.

MAGE - Memgraph Advanced Graph Extensions 🔮

High-Performance Erlang Stream Processor

Example akka application that uses the actor per request model

ARTML- Real time learning

The Refreshingly Simple Cross-Platform C++ Dataflow / Pipelining / Stream Processing / Reactive Programming Framework

Akka.Persistence.PostgreSql provider

A simple and eloquent workflow for streaming messages to micro-services.

Generate JVM (java, kotlin, scala) project with gradle / maven / sbt build systems and docker / docker-compose for rapid development

Akka plugin to collect various data about actors

Different ways to process data into Cassandra in realtime with technologies such as Kafka, Spark, Akka, Flink

Some class materials for a data processing course using PySpark

Example of a microservice with Scala, Akka, Spray and Camel/ActiveMQ

Logging backend for Akka based on Log4j

Theodolite is a framework for benchmarking the horizontal and vertical scalability of cloud-native applications.

TalariaDB is a distributed, highly available, and low latency time-series database for Presto

Readings in Stream Processing

Akka Cluster - absolute minimal

Simple shared surface streaming application

Atomic event store for Scala/Akka

A list of examples that involve streaming with Akka Streams and used together with Akka HTTP

A curated list of awesome big data frameworks, ressources and other awesomeness.

A mock Akka scheduler to simplify testing scheduler-dependent code

Stream Processing Library for Go

Apache Flink connectors for Pravega.

Scala DNS implementation with Akka and Netty extension

akka http gremlin 3 websocket connector

PowerAPI is a middleware toolkit for building software-defined power meters

Stream Discovery and Stream Orchestration

⚡A supercharged, interactive Kafka shell built on top of the existing Kafka CLI tools.

Play + Akka gRPC

Proto Actor - Ultra fast distributed actors for Go, C# and Java/Kotlin

Akka-Kotlin sample, and support library.

A web server application for Islamic prayer times

Telegram bot to generate self-authorizations for moving around during covid-19 pandemic in France

A project for exploring Akka with Scala

A stream processing language and compiler for small-scale monitoring

An Open-Source, Distributed MQTT Broker for IoT.

Small and simple stream-based CEP tool for IoT devices connected to an MQTT broker

Event sourcing framework based on ZIO and pluggable runtime (currently working with Akka cluster)