conduktor.io ↗

KIP-470 — TopologyTestDriver test input and output usability improvements

Discussion Kafka 2.4 StreamsTesting

Introduces strongly-typed `TestInputTopic<K,V>` and `TestOutputTopic<K,V>` wrappers for `TopologyTestDriver` with fluent pipe/read methods, deprecating the raw `ConsumerRecordFactory` and `pipeInput`/`readOutput` APIs. Existing `TopologyTestDriver` tests require verbose boilerplate—constructing `ConsumerRecord` objects manually and passing deserializers on every read—making topology tests significantly larger than the application code under test.

Details

AuthorJukka Karvanen
StatusDiscussion
Kafka Version2.4
JIRAKAFKA-8233
WikiView on Apache Wiki
Created2019-05-15
Last Modified2019-10-04
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.