Kafka streams at scale
summary
Explains using Kafka Streams for stateful real-time processing of multi-million event workloads, including an overview of event flow and Kafka Streams basics. Details practical challenges—fault recovery, horizontal scalability, cloud readiness, limitations of embedded RocksDB, and operating very large clusters—and describes code forks and engineering solutions implemented over the past year to address each issue, concluding with future work.
AI-written summary · about
chapters (16)
- 0:00Kafka Streams at Scale
- 0:24Stateful processing of multi- million events in real time
- 5:35Kafka Streams Challenges
- 6:12Recovery
- 8:07Cold Bootstrap
- 9:38Horizontal Scalability
- 10:13Repartitioning Logic
- 10:53Dynamic Repartitioning
- 12:09Scaling Lookups
- 14:19Cloud Readiness
- 14:35Rack/AZ Aware Task Assignment
- 16:02Partial Partition Assignment Revocation
- 20:04Large Clusters
- 20:30Rebalance Time Reduction
- 22:09Configs
- 28:13Up Next
related talks
29mApache Kafka and the Next 700 Stream Processing Systems
01h 00mKafka as a Platform: the Ecosystem from the Ground Up
53mDemystifying Kafka
17mOvercome By Events - Apache Kafka And Event-oriented Architecture
31mEvent Streaming with Kafka Streams
34mChasing the Stream Processing Utopia
41mKafka as a Platform: The Ecosystem from the Ground Up
39mKafka as a Platform: The Ecosystem from the Ground Up
