// the find
simplesteph/kafka-streams-course
Learn Kafka Streams with several examples!
Companion code for a Udemy course on Kafka Streams, covering the classic examples: word count, stateful aggregation, exactly-once semantics with bank balances, and KStream/GlobalKTable joins. It's a learning repo, not a library — the value is in following along with a course, not in dropping this into a project.
Each example is self-contained with its own Maven module, so you can run bank-balance without wading through word-count. The bank-balance module actually tests exactly-once semantics end-to-end with a producer + consumer, which is one of the harder concepts to see working in practice. The Scala version of the favourite-colour example is a nice bonus for people coming from that side.
Abandoned since 2022 — Kafka Streams has moved on (KIP-820, interactive queries improvements, Kafka 3.x changes) and none of that is reflected here. Almost no unit tests; only BankTransactionsProducer has a test class, and the rest of the examples have none. The README is basically a Udemy ad — there's no setup guide, no troubleshooting section, nothing to help someone who doesn't have the course. Tightly coupled to the course structure, so if you're not a paying student, the examples lack enough context to be self-explanatory.