Composing high performance process workflows with Akka Streams
summary
Shows replacing hand-wired actors with Akka Streams to define workflows in C#, F# and Scala, using the Akka materializer to create actors behind the scenes; demonstrates a real indexer that streams persistent events into Elasticsearch/Kibana and a Twitter pipeline that reads cached tweets at thousands/sec, uses broadcast+merge, and proves buffering per branch allows different consumer rates — without buffers a 1 msg/s throttle slows the whole source to 1 msg/s; adds parallel HTTP calls (up to 5) to a weather API and uses a materializer that wires actors automatically, achieving the intended dashboard and tweet outputs.
AI-written summary · about
chapters (10)
- 0:00Akka Streams intro
- 3:37Actors to workflows
- 10:23First Scala exposure
- 13:16Back pressure explained
- 16:53Streams building blocks
- 22:36Connectors for consuming
- 24:48Event journal case study
- 29:10Demo: streaming tweets
- 42:25Key takeaways
- 44:52Q&A
related talks
58mLife with actors: experience report
56mAkka in Heterogenous Environments
41mAkka in Production: Our Story
36mStream All The Things!
59mDrinking a river of IoT data with Akka.NET
47mStream All the Things!
41mA tale of futures, actors & pipes: using Akka for large data migration
33mKafka Microservices with Kafka plus Akka and Kafka Streams
