TopologyTestDriver¶

TopologyTestDriver helps writing tests to verify behavior of topologies (created with Topology or StreamsBuilder).

import org.apache.kafka.streams.TopologyTestDriver

Library Dependency¶

TopologyTestDriver belongs to a separate module and has to be defined as a dependency in a build configuration (e.g. build.sbt).

val kafkaVersion = "3.1.0"
libraryDependencies += "org.apache.kafka" % "kafka-streams-test-utils" % kafkaVersion % Test