310 Open source projects that are alternatives of or similar to Akka Stream Contrib

Scala library to eliminate boilerplate

Open source tools to simplify Akka event sourcing, journaling/persistence, serialization, clustering and sharding.

a curated list of awesome streaming frameworks, applications, etc

When Apache Pulsar meets Apache Spark

Golang Kafka consumer and producer example

scala、spark使用过程中，各种测试用例以及相关资料整理

Build highly concurrent, distributed, and resilient message-driven applications on the JVM

An example async Java REST API using Jersey 2 and Akka

flink learning blog. http://www.54tianzhisheng.cn/ 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例，还有 Flink 落地应用的大型项目案例（PVUV、日志存储、百亿数据实时去重、监控告警）分享。欢迎大家支持我的专栏《大数据实时计算引擎 Flink 实战与性能优化》

add-on to Akka Typed that tracks effects for use with Session Types

Real-time multiplayer sailing game, in your browser

This application comes as Spark2.1-as-Service-Provider using an embedded, Reactive-Streams-based, fully asynchronous HTTP server

一个基于 Play Framework 开发的开源社区系统。

Source code for the Kafka Streams in Action Book

Kafka Akka.Streams connectors - part of the Alpakka project

Event sourcing for Akka Streams

A framework for building spouts for Apache Storm and a Kafka based spout for dynamically skipping messages to be processed later.

Scala based lightweight service framework using akka and other popular technologies.

Simple, safe and intuitive Scala I/O

Files needed to try out KSQL Recipes for yourself

Dynamic execution framework for your Redis data

This toolkit is focused on interacting with popular messaging systems such as Kafka, JMS, XMS, and MQTT. After release v5.4.2 the complete toolkit will be deprecated. See the README.md file for hints to alternative toolkits.

Utilities for Akka cluster in production

Example usage of the Lagom Framework for writing Java-based microservices

Lithium - A split-brain resolver for Akka-Cluster

This toolkit supports common internet protocols, such as HTTP and WebSockets

A microservices-based Streaming and Batch data processing in Cloud Foundry and Kubernetes

🐟 A streaming ETL for fish

VectorSQL is a free analytics DBMS for IoT & Big Data, compatible with ClickHouse.

A reliable, high-performance tool for building observability data pipelines.

Scalable stream processing platform for advanced realtime analytics on top of Kafka and Spark. LogIsland also supports MQTT and Kafka Streams (Flink being in the roadmap). The platform does complex event processing and is suitable for time series analysis. A large set of valuable ready to use processors, data sources and sinks are available.

Evaluation of API and performance of different actor libraries

汇总Apache Hudi相关资料

Distributed State Management for Serverless

🎯 λ Hexagonal Architecture + DDD + CQRS applied in Scala using Akka HTTP

Upserts, Deletes And Incremental Processing on Big Data.

Java/Scala Examples from the book - Akka Essentials

Fast Parallel Async HTTP/SSH/TCP/UDP/Ping Client Java Library. Aggregate 100,000 APIs & send anywhere in 20 lines of code. Ping/HTTP Calls 8000 servers in 12 seconds. (Akka) www.parallec.io

⚛️ JustinDB is a highly available globally distributed key-value data store.

Elastic data processing with Apache Pulsar and Apache Flink

Sample demonstrating use of swagger-akka-http

Framework for building Event-Driven Microservices

Example of http (micro)service in Scala & akka-http

A high performance/ real-time C++ Kafka streams framework (C++17)

Akka Sample Projects

Lighthouse - a simple service discovery platform for Akka.Cluster (Akka.NET)

Python Stream Processing

Machine is a workflow/pipeline library for processing data

A stream processing API for Go (alpha)

A lightweight stream processing library for Go

A Python stream processing engine modeled after Yahoo! Pipes

Kafka client for functional streams for scala (fs2)

equivalent to kafka-streams 🐙 for nodejs ✨🐢🚀✨

Modern Load Testing as Code

Stream Processing and Complex Event Processing Engine

Streaming System 相关的论文读物

Integrate some of the best JSON libs in Scala with Akka HTTP

Cross-platform, customizable ML solutions for live and streaming media.

Reactive serial communication library for Akka and Scala.

Event Store Journal for Akka Persistence