Kafka Streams topics
12 short topics in Data Engineering and Analytics. Each one is a single focused exercise with a clear piece of evidence at the end.
12 topics, one exercise each.
Work through them in order, or jump to the one you need.
These are draft topic outlines (draft; instructor review pending). Full lessons follow after review; ask Ajay if you need a topic sooner.
- 01
Stream source and sink contracts
Demonstrate stream source and sink contracts in a focused Kafka Streams example; verify normal behavior and one edge or failure case. Keep the exercise bounded and record the behavior supported by the chosen version.
Open micro-course → - 02
Event time versus processing time
Demonstrate event time versus processing time in a focused Kafka Streams example; verify normal behavior and one edge or failure case. Keep the exercise bounded and record the behavior supported by the chosen version.
Open micro-course → - 03
Windowing and aggregation
Demonstrate windowing and aggregation in a focused Kafka Streams example; verify normal behavior and one edge or failure case. Keep the exercise bounded and record the behavior supported by the chosen version.
Open micro-course → - 04
Keyed state organization
Demonstrate keyed state organization in a focused Kafka Streams example; verify normal behavior and one edge or failure case. Keep the exercise bounded and record the behavior supported by the chosen version.
Open micro-course → - 05
State-store lifecycle
Demonstrate state-store lifecycle in a focused Kafka Streams example; verify normal behavior and one edge or failure case. Keep the exercise bounded and record the behavior supported by the chosen version.
Open micro-course → - 06
Late and out-of-order data
Demonstrate late and out-of-order data in a focused Kafka Streams example; verify normal behavior and one edge or failure case. Keep the exercise bounded and record the behavior supported by the chosen version.
Open micro-course → - 07
Join and enrichment patterns
Demonstrate join and enrichment patterns in a focused Kafka Streams example; verify normal behavior and one edge or failure case. Keep the exercise bounded and record the behavior supported by the chosen version.
Open micro-course → - 08
Processing guarantee boundaries
Demonstrate processing guarantee boundaries in a focused Kafka Streams example; verify normal behavior and one edge or failure case. Keep the exercise bounded and record the behavior supported by the chosen version.
Open micro-course → - 09
Checkpoint and recovery strategy
Demonstrate checkpoint and recovery strategy in a focused Kafka Streams example; verify normal behavior and one edge or failure case. Keep the exercise bounded and record the behavior supported by the chosen version.
Open micro-course → - 10
Schema change handling
Demonstrate schema change handling in a focused Kafka Streams example; verify normal behavior and one edge or failure case. Keep the exercise bounded and record the behavior supported by the chosen version.
Open micro-course → - 11
Throughput and lag diagnostics
Demonstrate throughput and lag diagnostics in a focused Kafka Streams example; verify normal behavior and one edge or failure case. Keep the exercise bounded and record the behavior supported by the chosen version.
Open micro-course → - 12
Stream-processing fixtures
Demonstrate stream-processing fixtures in a focused Kafka Streams example; verify normal behavior and one edge or failure case. Keep the exercise bounded and record the behavior supported by the chosen version.
Open micro-course →
Learn the same ideas beyond Kafka Streams.
These courses share topics with this one, so you can compare how each language or tool handles the same concept.
More in Messaging streaming and workflow engines.
You have the curiosity.
Let’s turn it into capability.
Start with a practical workshop or bring a specific question to Ajay.