Making Kafka Queryable with Apache Pinot
summary
Explains how Apache Pinot turns Kafka topics into a low-latency, SQL-queryable analytics store by ingesting Kafka directly into consuming segments on server nodes, writing immutable disk segments, and routing queries via brokers to servers; describes controller, minions and replication, and support for upserts. Shows the multi-stage vs single-stage engines, recommends low-level consumers for tight Kafka integration, and demonstrates the star-tree index that pre-aggregates dimensions to cut query time to ~50 ms at web scale with hundreds of servers and millions of segments.
AI-written summary · about
chapters (8)
- 0:00Introduction
- 1:24Database history
- 14:28Pinot architecture
- 28:33Indexes in Pinot
- 37:00StarTree and StarTree index
- 41:57Data ingestion
- 47:40Kafka integration
- 51:36Q&A
related talks
46mOptimizing Speed and Scale of User-Facing Analytics w Kafka and Pinot
54mAn Introduction to Apache Pinot
33mPinot, Why Are You So Fast?
49mIntroduction to Real-Time Analytics with Apache Pinot
44mUSER-FACING, REALTIME ANALYTICS USING APACHE PINOT
39mFaster Analytics for Fast Data with Apache Pinot and Flink SQL
34mReal-Time Analytics: Going Beyond Stream Processing with Apache Pinot
47mReal-time analytics for your users with Apache Pinot
