| 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.
|
| 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.
|
| StreamsConfig |
Configuration for a
KafkaStreams instance. |
| StreamsConfig.InternalConfig |
| Enum | Description |
|---|---|
| KafkaStreams.State |
Kafka Streams states are the possible state that a Kafka Streams instance can be in.
|