~/talk

Deploying Kafka Streams Applications...

Talkat Scale By The Bay 2018 · 2018-11-15..11-17· [microservices, kubernetes]
github:mjsax
slides:none on file

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

  1. 0:00Introduction to Kafka Streams
  2. 7:39Kafka Streams scaling deep dive
  3. 22:04Deploying on Kubernetes basics
  4. 32:01Stateful sets for Kafka Streams
  5. 34:56Live demo walkthrough
  6. 39:14Q&A and closing
~/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.