~/talk

Composing high performance process workflows with Akka Streams

Talkat NDC Oslo 2017 · 2017-06-14..06-16· [microservices]
slides:none on file

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

  1. 0:00Akka Streams intro
  2. 3:37Actors to workflows
  3. 10:23First Scala exposure
  4. 13:16Back pressure explained
  5. 16:53Streams building blocks
  6. 22:36Connectors for consuming
  7. 24:48Event journal case study
  8. 29:10Demo: streaming tweets
  9. 42:25Key takeaways
  10. 44:52Q&A
~/search
type to search 6,249 conferences, 138,987 speakers and 185,172 talks
~/help
cmdctrl k
search every conference, speaker and series
/
focus the filter search
h
home
c
conferences
s
speakers
e
series
t
light / dark — the status bar button does the same
?
this help
esc
close this, then clear every filter — or just the search, while you are typing in it

Ignored while you are typing. Pages without a filter rail have no search to focus.