conduktor.io ↗

KIP-267 — Add Processor Unit Test Support to Kafka Streams Test Utils

Accepted Kafka 2.0 StreamsTesting

KIP-267 adds a `MockProcessorContext` to the `kafka-streams-test-utils` module so developers can unit-test `Processor`, `Transformer`, and `ValueTransformer` implementations in isolation without starting a full `TopologyTestDriver`. Previously writing such tests required custom mock code for `ProcessorContext` that reproduced complicated internal behavior including state store registration, forwarding capture, and punctuator scheduling.

Details

AuthorJohn Roesler
StatusAccepted
Kafka Version2.0
JIRAKAFKA-6473
WikiView on Apache Wiki
Created2018-03-08
Last Modified2018-03-27
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.