Event Streaming with Kafka Streams
summary
Kafka Streams is a Java library that runs inside applications and implements scalable, stateful event processing by handling partition assignment when multiple instances with the same application.id join a consumer group. A concrete example shows grouping by key and doing counts (local state kept in a hashmap-like state store) and writing results to an output topic. The stack includes ZooKeeper (as of 12 Nov 2020) and optional schema registry for Avro/Protobuf; runnable tutorials ship via Docker.
AI-written summary · about
chapters (10)
- 0:00Introduction and welcome
- 1:31What is Kafka Streams
- 5:21Kafka as event streaming platform
- 9:16Kafka Streams high-level API
- 13:50Kafka application lifecycle
- 17:40Scalability and elasticity in Kafka Streams
- 21:33Where to run compute in stream processing
- 24:41Kafka Streams vs lambda architecture
- 26:50Learning resources and next steps
- 29:00Q&A and closing
related talks
37mEvent Streaming Applications with Kafka Streams, Spring Kafka and Actuator
29mApache Kafka and the Next 700 Stream Processing Systems
33mKafka streams at scale
01h 00mKafka as a Platform: the Ecosystem from the Ground Up
02h 05mA Deep Dive into Apache Kafka This is Event Streaming
08mPREVIEW: Kafka Stream Processing for Everyone with KSQL
51mStream Processing Smackdown: Kafka Streams vs. Apache Flink
17mOvercome By Events - Apache Kafka And Event-oriented Architecture
