TestInputTopic feeds serialized records into a Kafka Streams topology under test. Used with TopologyTestDriver, it simulates a Kafka input topic without requiring a running cluster or mock producers and consumers. section 10.3.1
A topology test uses TestInputTopic to:
- Specify the input topic name together with key and value serializers. section 10.3.1
- Pipe records through stateless or stateful processing nodes as serialized bytes. section 10.3.1
- Compare resulting records through TestOutputTopic while optionally simulating time and inspecting intermediate state. section 10.3.1
Topology test boundary
A test creates a TestInputTopic for an input stream, writes serialized events into it, and verifies transformed records on a TestOutputTopic. The topology runs locally, avoiding broker connectivity while exercising serialization and processing behavior. section 10.3.1
