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
-
Updated
Sep 27, 2024 - Scala
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
Akka Streams Connectors - Alpakka
This repository is a sample of using Akka Alpakka extension with Kafka broker to produce and consume data with handling back-pressure.
Example projects building Reactive Integrations using Alpakka
Clojure wrapper over Alpakka Kafka
Scala wrapper for the Pekko Connectors MQTT Streaming library and the Alpakka MQTT Streaming library.
A simple alternative to the Amazon SQS Daemon ("sqsd") used on AWS Beanstalk worker tier instances, based on https://github.com/mozart-analytics/sqsd
A clustered notification application which can deliver notifications to individual users or groups within a cluster.
Product Reviewer. Backend part of the source code for the post Fullstack Kafka
A data platform implementation for remote monitoring systems using asynchronous messaging
akka-persistence plugin for Apache Kafka
Alpakkeer is an opinionated toolkit to build, run and monitor applications based on Akka Streams and Alpakka.
A simple use case of an unbounded streaming of transactions into Kafka for downstream processes to consume.
Add a description, image, and links to the alpakka topic page so that developers can more easily learn about it.
To associate your repository with the alpakka topic, visit your repo's landing page and select "manage topics."