Kafka Deployment at Scale
summary
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
chapters (11)
- 0:00Criteo Kafka at scale
- 3:38Kafka scale metrics
- 9:19Custom Kafka drivers
- 12:32Migrating Kafka protocols
- 13:37Kafka latency SLAs
- 15:03Watermarks for ordering
- 20:28Kafka cluster isolation
- 22:15Spark Streaming challenges
- 27:21Streaming platform challenges
- 30:36Kafka protocol updates
- 32:30Q&A
related talks
13mScaling Kafka on Kubernetes
46mKafka Streams at the Big Data Crossroads at Lightning Speed
39m400 Billion Messages a Day with Kafka
53mDemystifying Kafka
32mScaling your Kafka streaming pipeline....
11mScaling Kafka in the Cloud
01h 00mKafka as a Platform: the Ecosystem from the Ground Up
29mKafka on Kubernetes: Does it really have to be the hard way?
