conduktor.io ↗

KIP-247 — Add public test utils for Kafka Streams

Accepted Kafka 1.1 StreamsTesting

Introduces a public `TopologyTestDriver` (and supporting `ConsumerRecordFactory`, `OutputVerifier`) in a stable `kafka-streams-test-utils` artifact for unit-testing Streams topologies without a real Kafka cluster. Previously, the only test utilities were internal classes in the test JAR with no stability guarantees, making it impractical to unit-test Streams applications.

Details

AuthorMatthias J. Sax
StatusAccepted
Kafka Version1.1
JIRAKAFKA-3625
WikiView on Apache Wiki
Created2018-01-08
Last Modified2018-01-24
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.