Package org.apache.kafka.streams

package org.apache.kafka.streams

Provides the Kafka Streams library for building streaming data applications.

Related Packages

Package	Description
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.
org.apache.kafka.streams.test	Provides classes for testing Kafka Streams applications with mocked inputs.

Class	Description
ClientInstanceIds	Encapsulates the client instance id used for metrics collection by producers, consumers, and the admin client used by Kafka Streams.
KafkaClientSupplier	KafkaClientSupplier can be used to provide custom Kafka clients to a KafkaStreams instance.
KafkaStreams	A Kafka client that allows for performing continuous computation on input coming from one or more input topics and sends output to zero, one, or more output topics.
KafkaStreams.CloseOptions	Class that handles options passed in case of KafkaStreams instance scale down
KafkaStreams.State	Kafka Streams states are the possible state that a Kafka Streams instance can be in.
KafkaStreams.StateListener	Listen to KafkaStreams.State change events.
KeyQueryMetadata	Represents all the metadata related to a key, where a particular key resides in a KafkaStreams application.
KeyValue<K,V>	A key-value pair defined for a single Kafka Streams record.
LagInfo	Encapsulates information about lag, at a store partition replica (active or standby).
StoreQueryParameters<T>	StoreQueryParameters allows you to pass a variety of parameters when fetching a store for interactive query.
StreamsBuilder	StreamsBuilder provides the high-level Kafka Streams DSL to specify a Kafka Streams topology.
StreamsConfig	Configuration for a KafkaStreams instance.
StreamsConfig.InternalConfig
StreamsMetadata	Metadata of a Kafka Streams client.
StreamsMetrics	The Kafka Streams metrics interface for adding metric sensors and collecting metric values.
TaskMetadata	Metadata of a task.
TestInputTopic<K,V>	TestInputTopic is used to pipe records to topic in TopologyTestDriver.
TestOutputTopic<K,V>	TestOutputTopic is used to read records from a topic in TopologyTestDriver.
ThreadMetadata	Metadata of a stream thread.
Topology	A logical representation of a ProcessorTopology.
Topology.AutoOffsetReset	Sets the auto.offset.reset configuration when adding a source processor or when creating KStream or KTable via StreamsBuilder.
TopologyConfig	Streams configs that apply at the topology level.
TopologyConfig.TaskConfig
TopologyDescription	A meta representation of a topology.
TopologyDescription.GlobalStore	Represents a global store.
TopologyDescription.Node	A node of a topology.
TopologyDescription.Processor	A processor node of a topology.
TopologyDescription.Sink	A sink node of a topology.
TopologyDescription.Source	A source node of a topology.
TopologyDescription.Subtopology	A connected sub-graph of a Topology.
TopologyTestDriver	This class makes it easier to write tests to verify the behavior of topologies created with Topology or StreamsBuilder.