See: Description
| Interface | 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.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 | 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 provides the high-level Kafka Streams DSL to specify a Kafka Streams topology. |
| StreamsConfig |
Configuration for a
KafkaStreams instance. |
| StreamsConfig.InternalConfig | |
| 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. |
| Topology |
A logical representation of a
ProcessorTopology. |
| TopologyConfig |
Streams configs that apply at the topology level.
|
| TopologyConfig.TaskConfig | |
| TopologyTestDriver |
This class makes it easier to write tests to verify the behavior of topologies created with
Topology or
StreamsBuilder. |
| 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. |