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
| Author | Jukka Karvanen |
| Status | Discussion |
| Kafka Version | 2.4 |
| JIRA | KAFKA-8233 |
| Wiki | View on Apache Wiki |
| Created | 2019-05-15 |
| Last Modified | 2019-10-04 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.