Latest

Kafka Streams Testing: TopologyTestDriver and Stateful Stream Processors

Testing

Kafka Streams Testing: TopologyTestDriver and Stateful Stream Processors

Kafka Streams provides a TopologyTestDriver that runs your entire stream processing topology in-process — no Kafka cluster needed. You pipe records in through TestInputTopic, read results from TestOutputTopic, and advance wall-clock time programmatically to test windowed aggregations. For Schema Registry integration, use MockSchemaRegistryClient to avoid hitting a real registry. Key Takeaways

By HelpMeTest