Package io.streamthoughts.azkarra.api.streams
-
Interface Summary Interface Description ApplicationIdBuilder Class for buildingStreamsConfig.APPLICATION_ID_CONFIG
.InternalStreamsLifeCycleChain.Callback KafkaStreamsContainer.StateChangeWatcher Watch aKafkaStreams
instance forKafkaStreams.State
change.KafkaStreamsFactory The interface which is used for creating newKafkaStreams
instance.TopologyProvider The default interface to supply a Kafka StreamsTopology
instance. -
Class Summary Class Description ApplicationId Simple class to wrap the value ofStreamsConfig.APPLICATION_ID_CONFIG
.InternalStreamsLifeCycleChain KafkaStreamContainerBuilder Default builder class for creating and configuring a new wrappedKafkaStreams
instance.KafkaStreamsContainer OptimizedTopologyProvider ATopologyProvider
that can be used to build an optimizedTopology
instance.StateChangeEvent StreamsServerInfo Class which is used to describe a stream application instance.TopicPartitions This class represents topic-partitions assignment for a streams application. -
Enum Summary Enum Description State The status for aKafkaStreams
instance.