Package org.apache.kafka.streams.test

package org.apache.kafka.streams.test

Provides classes for testing Kafka Streams applications with mocked inputs.

Related Packages

Package	Description
org.apache.kafka.streams	Provides the Kafka Streams library for building streaming data applications.
org.apache.kafka.streams.errors	Provides common exception classes for Streams applications.
org.apache.kafka.streams.kstream	Provides a high-level programming model (DSL) to express a (stateful) data flow computation over input streams and tables.
org.apache.kafka.streams.processor	Provides a low-level programming model (Processor API, aka, PAPI) to express a (stateful) data flow computation over input topics.
org.apache.kafka.streams.query	Provides a query API (aka Interactive Queries) over state stores, for extracting data from a stateful Kafka Streams application.
org.apache.kafka.streams.state	Provides interfaces for managing the intermediate state of a stateful streams application.

Classes

Class	Description
TestRecord<K,V>	A key/value pair, including timestamp and record headers, to be sent to or received from TopologyTestDriver.