Registry /
testing / kafka-streams-test-utils
Install & Compatibility
Where this runs
No compatibility data collected yet for this library.
Code
Verified usage
Verified import paths — ran on the pinned version, not inferred.
TestInputTopic
✓ org.apache.kafka.streams.TestInputTopic
Minimal test driver setup for Kafka Streams
import org.apache.kafka.streams.TestInputTopic;
import org.apache.kafka.streams.TopologyTestDriver;
import org.apache.kafka.streams.StreamsConfig;
import java.util.Properties;
public class Example {
public static void main(String[] args) {
Properties props = new Properties();
props.put(StreamsConfig.APPLICATION_ID_CONFIG, "test");
props.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, "dummy:1234");
TopologyTestDriver testDriver = new TopologyTestDriver(buildTopology(), props);
TestInputTopic<String, String> inputTopic = testDriver.createInputTopic("input",
new StringSerializer(), new StringSerializer());
System.out.println("Test driver created");
}
static Topology buildTopology() { return null; }
}
Debug
Known issues
No known issues recorded.
Audit
Dependencies
No dependency data recorded yet.