| 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
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.
|
| 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. |
| 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. |