Deploying Kafka Streams Applications...
summary
Kafka Streams runs as partitioned tasks with a one-to-one task-to-partition mapping and local state backed by a compacted changelog topic, so scaling requires migrating those state shards. Kubernetes deploys these as containers; demo uses StatefulSet volumes, scales from two to three replicas, and recovers state from local disk or the changelog. Practical tips include using statefulset with anti-affinity, starting pods in parallel, setting a reasonable disruption budget, and reduce log segment size to cut recovery time for small states.
AI-written summary · about
chapters (6)
- 0:00Introduction to Kafka Streams
- 7:39Kafka Streams scaling deep dive
- 22:04Deploying on Kubernetes basics
- 32:01Stateful sets for Kafka Streams
- 34:56Live demo walkthrough
- 39:14Q&A and closing
related talks
35mStreams Must Flow: Fault-tolerant streams processing apps on Kubernetes
30mDeploying SQL Stream Processing in Kubernetes with Ease
13mScaling Kafka on Kubernetes
33mKafka Microservices with Kafka plus Akka and Kafka Streams
33mKafka Operator: Managing and Operating Kafka Clusters in Kubernetes [A]
27mRunning Kafka in Kubernetes a practical guide
41mApache Kafka + Apache Mesos = Highly Scalable Streaming Microservices
24mMake Your Kafka Cluster Production-Ready
