Package org.apache.kafka.streams
package org.apache.kafka.streams
Provides the Kafka Streams library for building streaming data applications.
-
ClassDescription
KafkaClientSupplier
can be used to provide custom Kafka clients to aKafkaStreams
instance.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.Class that handles options passed in case ofKafkaStreams
instance scale downKafka Streams states are the possible state that a Kafka Streams instance can be in.Listen toKafkaStreams.State
change events.Represents all the metadata related to a key, where a particular key resides in aKafkaStreams
application.KeyValue<K,V> A key-value pair defined for a single Kafka Streams record.Encapsulates information about lag, at a store partition replica (active or standby).StoreQueryParameters
allows you to pass a variety of parameters when fetching a store for interactive query.StreamsBuilder
provide the high-level Kafka Streams DSL to specify a Kafka Streams topology.Configuration for aKafkaStreams
instance.Metadata of a Kafka Streams client.The Kafka Streams metrics interface for adding metric sensors and collecting metric values.Metadata of a task.TestInputTopic<K,V> TestInputTopic
is used to pipe records to topic inTopologyTestDriver
.TestOutputTopic<K,V> TestOutputTopic
is used to read records from a topic inTopologyTestDriver
.Metadata of a stream thread.A logical representation of aProcessorTopology
.Sets theauto.offset.reset
configuration whenadding a source processor
or when creatingKStream
orKTable
viaStreamsBuilder
.Streams configs that apply at the topology level.A meta representation of atopology
.Represents aglobal store
.A node of a topology.A processor node of a topology.A sink node of a topology.A source node of a topology.A connected sub-graph of aTopology
.This class makes it easier to write tests to verify the behavior of topologies created withTopology
orStreamsBuilder
.