Fast Production and Consumption with Reactive Streams: Akka Stream

Overview

We use Akka-stream do build Reactive Stream Based mico-services to both produce to and consume from the pipeline. These components are necessary to produce fast enough to the pipeline and consume fast enough from the pipeline. The Akka-stream library enable to write very complex asynchronous processing graph that make an optimal use of the multi-core architecture of the node on which the final component is deployed, to provide for highly concurrent component with automated back-pressure.

Introduction to Reactive Stream

• Reactive Revealed

• Understanding Akka Stream, Back Pressure and Asynchronous Architecture

• Exploring Reactive Integration with Akka Stream, Alpakka, and Kafka

• Learn Lesson from Paypal: Implementing BackPressure with Akka Stream and Kafka

• Mastering AKKA - Chapter 6 - Going with the Flow with Akka

• Akka in Action - Chapter 13 - Streaming

Illustration

-The project ReactiveConsumers and ReactiveProducers contains the components that make use of AKKA-Stream

-For a easier introduction, and to play around with, check the projects ReactiveFolderCopier, ReactiveFolderReader, ReactiveKafkaFsProducer within the Demos projects which aggregate all our demos. A Supporting Hands-on Video Tutorial is also provided