Package org.apache.kafka.streams
-
Interface Summary Interface Description KafkaClientSupplier KafkaClientSupplier
can be used to provide custom Kafka clients to aKafkaStreams
instance.KafkaStreams.StateListener Listen toKafkaStreams.State
change events.StreamsMetrics The Kafka Streams metrics interface for adding metric sensors and collecting metric values.TopologyDescription A meta representation of atopology
.TopologyDescription.GlobalStore Represents aglobal 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 aTopology
. -
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 aKafkaStreams
instance.StreamsConfig.InternalConfig Topology A logical representation of aProcessorTopology
. -
Enum Summary Enum Description KafkaStreams.State Kafka Streams states are the possible state that a Kafka Streams instance can be in.Topology.AutoOffsetReset Sets theauto.offset.reset
configuration whenadding a source processor
or when creatingKStream
orKTable
viaStreamsBuilder
.