229 Open source projects that are alternatives of or similar to Kafka With Akka Streams Kafka Streams Tutorial

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

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

Akka Streams & Akka HTTP for Large-Scale Production Deployments

Diagram- and graph-generating library for Akka Streams

Utilities for Akka cluster in production

ZIO wrapper for Akka Cluster

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

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

A journal and snapshot store plugin for akka-persistence using RDBMS.

The Streaming-first HTTP server/module of Akka

Open-source IoT Platform - Device management, data collection, processing and visualization.

Simple, safe and intuitive Scala I/O

Kafka Tutorials microsite

OpenTracing Instrumentation for Apache Kafka Client

Add-ons to Akka Stream

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.

Lithium - A split-brain resolver for Akka-Cluster

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

Thin Scala wrapper around Kafka Streams Java API

Sample demonstrating use of swagger-akka-http

Scala and Akka for kids. A Functional Programming approach for the well known LOGO.

A real-time data replication platform that "unbundles" the receiving, transforming, and transport of data streams.

StreamLine - Streaming Analytics

Machine Learning Platform and Recommendation Engine built on Kubernetes

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

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

Open source AMQP messaging broker based on Akka

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

.NET Stream Processing Library for Apache Kafka 🚀

A REPL for Apache Kafka

Real-time multiplayer sailing game, in your browser

Quorum split brain resolver for static akka cluster

JVM Bloggers - website and newsletter with JVM blogs from Poland

Implementation of akka-persistence storage plugins for mongodb

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

A Clojure DSL for Kafka Streams

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

Code to share the knowledge I gained while designing and implementing micro services

Evaluation of API and performance of different actor libraries

Clickhouse Scala Client with Reactive Streams support

Apache Kafka running on Kubernetes

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

Reactive serial communication library for Akka and Scala.

Event Store Journal for Akka Persistence

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

A collection of kafka-resources

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

Scala DSL for Unit-Testing Processing Topologies in Kafka Streams

Destroys failures.

Scala library to eliminate boilerplate

Kattlo CLI Project

Kafka ecosystem ... but step by step!

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

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

Real Time Big Data / IoT Machine Learning (Model Training and Inference) with HiveMQ (MQTT), TensorFlow IO and Apache Kafka - no additional data store like S3, HDFS or Spark required

Distributed web chat application base websocket built on akka.

Lightweight api management on top of a modern http reverse proxy

🚀 Azkarra is a lightweight java framework to make it easy to develop, deploy and manage cloud-native streaming microservices based on Apache Kafka Streams.