Stream Processing, Going Beyond Pub/Sub with Kafka Streams and...
summary
Concrete stream-processing pipelines using Kafka ecosystem components are presented: CDC with Debezium and Kafka Connect into Avro with Schema Registry, ingesting sources like a Pac‑Man game and Norwegian boat GPS into Kafka topics; processing with Kafka Streams and ksqlDB performing joins and windowing, using RocksDB state stores with standby replicas for recovery. The talk covers operational tradeoffs (ordering, late arrivals, windowing, exactly‑once), performance at LinkedIn scale and partitioning cautions, and shows real failure modes and fixes demonstrated on Confluent Cloud.
AI-written summary · about
chapters (6)
- 0:00Introduction
- 18:24Streaming key concepts
- 1:00:10Pac-Man demo with Kafka
- 1:38:26Q&A
- 1:49:19Aggregations and testing
- 2:51:57Summary
related talks
01h 29mEvent stream processing using Kafka Streams
01h 00mIn Depth Kafka Streams
01h 07mKafka Streams and KSQLDB
50mApplication development and data in the emerging world ...
06mJay Kreps interview
55mDemystifying Stream Processing with Apache Kafka
45mApplications in the Emerging World of Stream Processing
43mApache Kafka and KSQL in Action: Let’s Build a Streaming Data Pipeline!
