Kafka Streams in Production

KStream/KTable, state stores, windowing, joins, topology, rebalancing, and interactive queries.

Build stream processors with nothing but a JVM library — KStream/KTable duality, stateful operations and RocksDB state stores, windowing, joins, the topology-to-tasks mapping, rebalance behavior, and interactive queries.

Intermediate10 chapters· 3h 30m· in Ingestion & Transport

Course content

  1. 01Why Kafka Streams: A Library, Not a ClusterFree
  2. 02KStream & KTable: The Duality🔒
  3. 03Stateful Operations & State Stores (RocksDB)🔒
  4. 04Windowing: Tumbling, Hopping, Session🔒
  5. 05Joins: Stream-Stream, Stream-Table, Table-Table🔒
  6. 06The Topology & How It Maps to Tasks and Threads🔒
  7. 07Rebalancing, Standby Replicas & Recovery🔒
  8. 08Interactive Queries🔒
  9. 09Testing & Operating a Streams App🔒
  10. 10Capstone: Real-Time Order Enrichment for TheWorldShop🔒

Prerequisites

What to learn next

Read the first chapter free

Start reading now — no account required for the free chapters.