TopologyTestDriver

A Kafka Streams test utility that runs a topology in memory without a broker.

Tests pipe records into input topics, read what the topology writes to output topics and inspect state stores. Wall-clock time only moves when the test advances it, so punctuations and windows are deterministic.