Package io.streamthoughts.azkarra.api.streams
-
Interface Summary Interface Description ApplicationIdBuilder Class for buildingStreamsConfig.APPLICATION_ID_CONFIG
.KafkaStreamsContainer AKafkaStreamsContainer
is used to encapsulate and to manipulate aKafkaStreams
instance that can be running either locally or remotely.KafkaStreamsContainer.KafkaMetricFilter AKafkaMetricFilter
can be used to only get specific metrics.KafkaStreamsContainer.StateChangeWatcher Watch aKafkaStreams
instance forKafkaStreams.State
change.KafkaStreamsContainerAware Interface to be implemented by any object that wishes to be notified of theKafkaStreamsContainer
that it runs in.KafkaStreamsFactory The interface which is used for creating newKafkaStreams
instance.State Interface that can be used to set the state of theKafkaStreamsContainer
.TopologyProvider The default interface to supply a Kafka StreamsTopology
instance. -
Class Summary Class Description KafkaStreamsApplication AKafkaStreamsApplication
regroups information aboutKafkaStreams
instances that use the sameapplication.id
,i.e., all instances that belong to the same Kafka Streams application.KafkaStreamsInstance AKafkaStreamsInstance
regroups information about a Kafka Streams instance running either locally or remotely.KafkaStreamsMetadata AKafkaStreamsMetadata
regroups information about resources assigned to a stream application instance, i.e., a set of Topic/Partitions and state stores.OptimizedTopologyProvider ATopologyProvider
that can be used to build an optimizedTopology
instance.StateChangeEvent TopicPartitions This class represents topic-partitions assignment for a streams application. -
Enum Summary Enum Description State.Standards The standardState
for aKafkaStreams
instance.