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.
StreamsMetrics	The Kafka Streams metrics interface for adding metric sensors and collecting metric values.
TopologyDescription	A meta representation of a topology.
TopologyDescription.GlobalStore	Represents a Topology.addGlobalStore(org.apache.kafka.streams.processor.StateStoreSupplier, String, org.apache.kafka.common.serialization.Deserializer, org.apache.kafka.common.serialization.Deserializer, String, String, ProcessorSupplier) 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.
KeyValue<K,V>	A key-value pair defined for a single Kafka Streams record.
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.

Enum Summary

Enum	Description
KafkaStreams.State	Kafka Streams states are the possible state that a Kafka Streams instance can be in.
Topology.AutoOffsetReset	Enum used to define auto offset reset policy when creating KStream or KTable