Streaming all the things with Akka Streams

on YouTube ↗48m

" summary

Akka Streams implements Reactive Streams on the JVM and shows three concrete APIs: Source/Flow/Sink for linear pipelines, Graph DSL for arbitrary graphs, and the low‑level GraphStage API for custom stages. Examples include a Source emitting 0..20 million ints without holding them in memory, an HTTP endpoint that streams numbers with TCP backpressure propagating to the source, a WebSocket flow that batches up to 1000 messages or 1s then calls an async CompletionStage to write to a DB, and Alpakka connectors (Kafka, Cassandra, RabbitMQ, DynamoDB). The materializer fuses stages into an ActorSystem actor; the project has ~200 contributors.

AI-written summary · about

" chapters (15)

1. 0:00Intro
2. 1:47What's in the toolkit?
3. 3:35Reactive Streams timeline
4. 10:22Akka Streams in -20 seconds
5. 15:54Numbers as a service
6. 18:11Back pressure over TCP
7. 19:57A Amore useful example
8. 23:33The tale of the two pancake chefs
9. 24:29Rolands pipelined pancakes
10. 27:00Patriks parallel pancakes
11. 29:54Making pancakes together
12. 30:26Built in stages
13. 32:37GraphStage API
14. 35:49A what about distributed reactive systems
15. 37:01The community

" related talks

• 30mLEARN YOU AKKA STREAMS FOR GREAT GOOD!Heiko Seeberger · Scalar Conference 2017
• 28mStreams on top of ScalaQuentin Adam · Scalar Conference 2015
• 01h 07mA Practical Introduction to Akka StreamsJacek Kunicki · JDD 2016
• 31mSTREAM DRIVEN DEVELOPMENT - DESIGN YOUR DATA PIPELINE WITH AKKA STREAMSStefano Bonetti · Scalar 2018
• 54mHow I Learned to Stop Worrying & Love the FlowViktor Klang · GOTO Copenhagen 2014
• 46mTame Your Data with Akka StreamsJacek Kunicki · Scale By the Bay 2017
• 01h 20mAkka Streams for Large Scale Data ProcessingZack Loebel-Begelman, Dustin Lyons · Data By the Bay 2016
• 33mKafka Microservices with Kafka plus Akka and Kafka StreamsBoris Lublinsky · Scala Days Berlin 2018