Real-Time Data Analysis with Apache Kafka
summary
A practical walkthrough of Kafka Streams showing a Java word-count example that uses flatMap → groupBy → count, writes results to a topic, and builds a KTable-backed state stored locally in RocksDB with two internal topics. Covers Kafka Streams features: exactly-once delivery semantics, partition-count requirements for joins, scaling limits tied to partition count, runtime thread-per-instance behavior (avoid colocating with brokers), integration via Kafka Connect, and a comparison with Spark Streaming and Flink.
AI-written summary · about
chapters (9)
- 0:00Kafka intro
- 6:02Kafka basics & benefits
- 13:24Kafka Streams processing
- 27:35Kafka Streams code
- 35:17Scaling Kafka Streams
- 41:57Kafka Streams vs alternatives
- 48:37Kafka in IoT
- 50:22Kafka monitoring
- 54:19Summary & Q&A
related talks
01h 00mIn Depth Kafka Streams
01h 29mEvent stream processing using Kafka Streams
45mApplications in the Emerging World of Stream Processing
50mIntroduction to Apache Kafka
01h 07mKafka Streams and KSQLDB
39mAn introduction to Apache Kafka - this is Event Streaming, not just Messaging
55mDemystifying Stream Processing with Apache Kafka
50mStream Processing Smackdown: Kafka Streams vs. Apache Flink
