Package | Description |
---|---|
org.apache.kafka.streams |
Provides the Kafka Streams library for building streaming data applications.
|
org.apache.kafka.streams.errors |
Provides common exception classes for Streams applications.
|
org.apache.kafka.streams.kstream | |
org.apache.kafka.streams.processor |
Provides a low-level programming model (Processor API, aka, PAPI) to express a (stateful) data flow computation over input topics.
|
org.apache.kafka.streams.processor.api |
Provides a low-level programming model (Processor API, aka, PAPI) to express a (stateful) data flow computation over input topics.
|
org.apache.kafka.streams.processor.assignment | |
org.apache.kafka.streams.processor.assignment.assignors | |
org.apache.kafka.streams.query |
Provides a query API (aka Interactive Queries) over state stores, for extracting data from a stateful Kafka Streams application.
|
org.apache.kafka.streams.state |
Provides interfaces for managing the intermediate state of a stateful streams application.
|