The three paths of Scaling with Akka
summary
A concrete walkthrough shows a conference-management microservice built with Scala using Akka Cluster Sharding, Cassandra persistence and Kafka write API; it implements event sourcing, CQRS and passivation with snapshots taken every five events, and uses hash(ID) mod nodes for data partitioning. The demo runs three nodes with four shards, reproduces the guarantee that the same entity ID is handled by the same node until rebalance, persists events to Cassandra (replication example: 3 of 5 replicas) and produces Kafka outputs.
AI-written summary · about
chapters (34)
- 0:00Intro
- 0:30Agenda
- 2:06Scaling
- 4:45Decomposer
- 5:15Consistency
- 8:01Questions
- 8:34Architecture
- 10:13Events
- 11:25Entities
- 12:16Duplication
- 13:09Model Application
- 13:39Application Module
- 14:35Kafka API
- 15:03Kafka Events
- 15:56Kafka Helper
- 16:09Data Partitioning
- 17:12Entity Actor
- 17:43Passivation
- 20:02Translation
- 20:14Persistence
- 20:36Recovery
- 21:34Horizontal duplication
- 21:47Cassandra persistence
- 22:01Snapshot
- 22:54Snapshot Persistence
- 23:53Snapshot Messages
- 25:00Cassandra
- 25:44Service
- 26:02Application
- 26:58Demo
- 34:00Common problems
- 38:20Cassandra query
- 41:17Rebalancing
- 42:38Cluster Management
related talks
55mExperience report on using Akka in production: pitfalls and rewards
51mImplementing Microservices with Scale and Akka
59mImplementing Microservices with Scala and Akka
57mBuilding Stateful Clustered Microservices with Java, Actors, and Kubernetes
41mAkka in Production: Our Story
45mReactive Microservices with Akka and Docker
44mLong-lived microservices
37mBuilding a Distributed Task Scheduler With Akka, Kafka, and Cassandra