Package org.apache.kafka.streams

Interface Summary

Interface	Description
KafkaClientSupplier	KafkaClientSupplier can be used to provide custom Kafka clients to a KafkaStreams instance.
KafkaStreams.StateListener	Listen to KafkaStreams.State change events.
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.
ThreadMetadata	Metadata of a stream thread.
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.

Class Summary

Class	Description
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
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 provide the high-level Kafka Streams DSL to specify a Kafka Streams topology.
StreamsConfig	Configuration for a KafkaStreams instance.
StreamsConfig.InternalConfig
Topology	A logical representation of a ProcessorTopology.
TopologyConfig	Streams configs that apply at the topology level.
TopologyConfig.TaskConfig

Enum Summary

Enum	Description
KafkaStreams.State	Kafka Streams states are the possible state that a Kafka Streams instance can be in.
Topology.AutoOffsetReset	Sets the auto.offset.reset configuration when adding a source processor or when creating KStream or KTable via StreamsBuilder.