Speck flavored streaming micro services with Akka
summary
Spekka provides concrete additions to Akka Streams: a flow with extended context that enforces one‑to‑one semantics and supports reordering operators; a partitioning tree that does keyed and multicast routing (universe + actor example) and produces multiple outputs while retaining input context; stateful flows with durable backends (in‑memory or Cassandra persistence), before/after side‑effect hooks to get at‑least‑once behavior, a control API to query running totals, and transparent Akka Cluster Sharding integration that distributes entity flows across a cluster.
AI-written summary · about
chapters (17)
- 0:00Introduction and speaker intro
- 1:03What is Speca project
- 2:51Desired properties of streaming microservices
- 7:13Akka Streams fundamentals
- 9:22Problem with Akka Streams flows
- 10:50Flow with extended context
- 12:16Demo: Rolling total duration
- 14:49Demo: Grouping by universe
- 16:40Demo: Grouping by actor and universe
- 20:37Other Speca operators
- 23:27Stateful flows introduction
- 27:25Stateful flow logic and backend
- 31:00Demo: Interactive stateful flow
- 32:25Side effect ordering guarantees
- 34:52Persistent stateful flows
- 37:00Scaling with Akka Cluster
- 38:45Conclusion and Q&A
related talks
48mStreaming all the things with Akka Streams
36mStream All The Things!
33mKafka Microservices with Kafka plus Akka and Kafka Streams
28mStreams on top of Scala
35mOne year with Akka 2.6
47mStream All the Things!
51mImplementing Microservices with Scale and Akka
51mComposing high performance process workflows with Akka Streams