~/talk

Stream Processing Smackdown: Kafka Streams vs. Apache Flink

Talkat Jfokus 2025 · 2025-02-03..02-05· [data-engineering]
slides:none on file

Direct comparison of Kafka Streams and Flink with live-coded examples shows how each handles state, fault tolerance, and scaling: Kafka Streams uses a RocksDB-backed state store and consumer-group partitioning with optional standby replicas for faster recoveries; Flink runs jobs on a clustered JobManager/TaskManager model with incremental checkpoints and watermark-driven windows. Example pipeline computes flight delays using a 15-minute sliding window with a one-minute advance and demonstrates exactly-once semantics end-to-end when enabled.

AI-written summary · about

  1. 0:00Stream processing comparison
  2. 2:50Stream processing basics
  3. 8:04Kafka scalability
  4. 13:09Kafka Streams architecture
  5. 16:40Kafka Streams demo
  6. 20:53Flink architecture
  7. 24:24Flink processing example
  8. 29:23State management comparison
  9. 32:10Scalability differences
  10. 37:29Time and window ops
  11. 41:06Exactly-once semantics
  12. 46:07Kafka Streams vs Flink
~/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.