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
This repository is a sample of using Akka Alpakka extension with Kafka broker to produce and consume data with handling back-pressure.
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.
A data platform implementation for remote monitoring systems using asynchronous messaging
akka-persistence plugin for Apache Kafka
A simple use case of an unbounded streaming of transactions into Kafka for downstream processes to consume.
Akka Stream library for Azure IoT Hub
Alpakka Connector for MapR-Database
Example data processing pipeline with Akka Streams and Alpakka using Scala
Giter8 template for an Akka Streams projectusing RIoT, RIoT-Control, and SBT
An example kafka log consumer using Alp-Akka and Akka Streams
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."