~/talk

Event Streaming with Kafka Streams

Talkat Scale By the Bay 2020 · on Friday, 2020-11-13· at 01:00· cloud, Online· [databases]
slides:none on file

Kafka Streams is a Java library that runs inside applications and implements scalable, stateful event processing by handling partition assignment when multiple instances with the same application.id join a consumer group. A concrete example shows grouping by key and doing counts (local state kept in a hashmap-like state store) and writing results to an output topic. The stack includes ZooKeeper (as of 12 Nov 2020) and optional schema registry for Avro/Protobuf; runnable tutorials ship via Docker.

AI-written summary · about

  1. 0:00Introduction and welcome
  2. 1:31What is Kafka Streams
  3. 5:21Kafka as event streaming platform
  4. 9:16Kafka Streams high-level API
  5. 13:50Kafka application lifecycle
  6. 17:40Scalability and elasticity in Kafka Streams
  7. 21:33Where to run compute in stream processing
  8. 24:41Kafka Streams vs lambda architecture
  9. 26:50Learning resources and next steps
  10. 29:00Q&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.