AzkarraContext |
The AzkarraContext.
|
AzkarraContextAware |
Interface to be implemented by any object that wishes to be notified of the AzkarraContext that it runs in.
|
AzkarraContextListener |
|
AzkarraStreamsService |
The AzkarraStreamsService serves as the main front-facing interface for manipulating streams applications.
|
ContainerId |
An interface representing an ID to uniquely identify a KafkaStreams instance running either locally or remotely.
|
StreamsExecutionEnvironment<T extends StreamsExecutionEnvironment<T>> |
A StreamsExecutionEnvironment manages the execution and the lifecycle of one or many KafkaStreams
instances that run either locally or remotely.
|
StreamsExecutionEnvironmentAware |
|
StreamsExecutionEnvironmentFactory<T extends StreamsExecutionEnvironment<T>> |
|
StreamsLifecycleChain |
|
StreamsLifecycleContext |
Context about the current KafkaStreams instance.
|
StreamsLifecycleInterceptor |
An interface that allows to intercept a KafkaStreams instance before being
started or stopped.
|
StreamsTopologyExecution |
TopologyExecution provide a way for topology to be executed in an specific environment.
|