~/talk

Kafka Deployment at Scale

TalkinRussianat Highload fwdays'19 · on Saturday, 2019-10-05· [kubernetes, databases]
stackoverflow:1554314
slides:none on file

Criteo describes operating Kafka at massive scale: 10 million messages/sec (~500B/day) and ~180 TB/day compressed across ~14 clusters with 72‑hour retention and topics up to 1,300 partitions. The deployment uses a custom C# Kafka driver, a watermark injector for latency measurement, a custom Kafka Connect replicator between datacenters, separate front vs application clusters, and a slow‑broker blacklist; streaming processing is done with Spark and Flink while addressing partition imbalance and ordering/out‑of‑order join challenges during a protocol upgrade from 0.10 to 0.11.

AI-written summary · about

  1. 0:00Criteo Kafka at scale
  2. 3:38Kafka scale metrics
  3. 9:19Custom Kafka drivers
  4. 12:32Migrating Kafka protocols
  5. 13:37Kafka latency SLAs
  6. 15:03Watermarks for ordering
  7. 20:28Kafka cluster isolation
  8. 22:15Spark Streaming challenges
  9. 27:21Streaming platform challenges
  10. 30:36Kafka protocol updates
  11. 32:30Q&A
~/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.