Uses of Package
io.streamthoughts.azkarra.api.streams
-
Classes in io.streamthoughts.azkarra.api.streams used by io.streamthoughts.azkarra.api Class Description ApplicationIdBuilder Class for buildingStreamsConfig.APPLICATION_ID_CONFIG
.KafkaStreamsApplication AKafkaStreamsApplication
regroups information aboutKafkaStreams
instances that use the sameapplication.id
,i.e., all instances that belong to the same Kafka Streams application.KafkaStreamsContainer AKafkaStreamsContainer
is used to encapsulate and to manipulate aKafkaStreams
instance that can be running either locally or remotely.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. -
Classes in io.streamthoughts.azkarra.api.streams used by io.streamthoughts.azkarra.api.providers Class Description TopologyProvider The default interface to supply a Kafka StreamsTopology
instance. -
Classes in io.streamthoughts.azkarra.api.streams used by io.streamthoughts.azkarra.api.streams Class Description 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.KafkaStreamsFactory The interface which is used for creating newKafkaStreams
instance.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.State Interface that can be used to set the state of theKafkaStreamsContainer
.State.Standards The standardState
for aKafkaStreams
instance.StateChangeEvent TopicPartitions This class represents topic-partitions assignment for a streams application.TopologyProvider The default interface to supply a Kafka StreamsTopology
instance. -
Classes in io.streamthoughts.azkarra.api.streams used by io.streamthoughts.azkarra.api.streams.errors Class Description KafkaStreamsContainer AKafkaStreamsContainer
is used to encapsulate and to manipulate aKafkaStreams
instance that can be running either locally or remotely. -
Classes in io.streamthoughts.azkarra.api.streams used by io.streamthoughts.azkarra.api.streams.listener Class Description KafkaStreamsContainer AKafkaStreamsContainer
is used to encapsulate and to manipulate aKafkaStreams
instance that can be running either locally or remotely.KafkaStreamsContainerAware Interface to be implemented by any object that wishes to be notified of theKafkaStreamsContainer
that it runs in. -
Classes in io.streamthoughts.azkarra.api.streams used by io.streamthoughts.azkarra.http.data Class Description KafkaStreamsMetadata AKafkaStreamsMetadata
regroups information about resources assigned to a stream application instance, i.e., a set of Topic/Partitions and state stores. -
Classes in io.streamthoughts.azkarra.api.streams used by io.streamthoughts.azkarra.runtime.context Class Description TopologyProvider The default interface to supply a Kafka StreamsTopology
instance. -
Classes in io.streamthoughts.azkarra.api.streams used by io.streamthoughts.azkarra.runtime.context.internal Class 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.KafkaStreamsFactory The interface which is used for creating newKafkaStreams
instance.TopologyProvider The default interface to supply a Kafka StreamsTopology
instance. -
Classes in io.streamthoughts.azkarra.api.streams used by io.streamthoughts.azkarra.runtime.env Class Description ApplicationIdBuilder Class for buildingStreamsConfig.APPLICATION_ID_CONFIG
.KafkaStreamsApplication AKafkaStreamsApplication
regroups information aboutKafkaStreams
instances that use the sameapplication.id
,i.e., all instances that belong to the same Kafka Streams application.KafkaStreamsContainer AKafkaStreamsContainer
is used to encapsulate and to manipulate aKafkaStreams
instance that can be running either locally or remotely.KafkaStreamsFactory The interface which is used for creating newKafkaStreams
instance.TopologyProvider The default interface to supply a Kafka StreamsTopology
instance. -
Classes in io.streamthoughts.azkarra.api.streams used by io.streamthoughts.azkarra.runtime.interceptors.monitoring Class Description KafkaStreamsContainer AKafkaStreamsContainer
is used to encapsulate and to manipulate aKafkaStreams
instance that can be running either locally or remotely.KafkaStreamsContainerAware Interface to be implemented by any object that wishes to be notified of theKafkaStreamsContainer
that it runs in.State Interface that can be used to set the state of theKafkaStreamsContainer
. -
Classes in io.streamthoughts.azkarra.api.streams used by io.streamthoughts.azkarra.runtime.query Class Description KafkaStreamsContainer AKafkaStreamsContainer
is used to encapsulate and to manipulate aKafkaStreams
instance that can be running either locally or remotely. -
Classes in io.streamthoughts.azkarra.api.streams used by io.streamthoughts.azkarra.runtime.service 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.KafkaStreamsContainer AKafkaStreamsContainer
is used to encapsulate and to manipulate aKafkaStreams
instance that can be running either locally or remotely.TopologyProvider The default interface to supply a Kafka StreamsTopology
instance. -
Classes in io.streamthoughts.azkarra.api.streams used by io.streamthoughts.azkarra.runtime.streams Class 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.KafkaStreamsFactory The interface which is used for creating newKafkaStreams
instance.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.State Interface that can be used to set the state of theKafkaStreamsContainer
. -
Classes in io.streamthoughts.azkarra.api.streams used by io.streamthoughts.azkarra.runtime.streams.errors Class Description KafkaStreamsContainer AKafkaStreamsContainer
is used to encapsulate and to manipulate aKafkaStreams
instance that can be running either locally or remotely. -
Classes in io.streamthoughts.azkarra.api.streams used by io.streamthoughts.azkarra.runtime.streams.topology Class Description KafkaStreamsFactory The interface which is used for creating newKafkaStreams
instance. -
Classes in io.streamthoughts.azkarra.api.streams used by io.streamthoughts.examples.azkarra.conditional Class Description TopologyProvider The default interface to supply a Kafka StreamsTopology
instance. -
Classes in io.streamthoughts.azkarra.api.streams used by io.streamthoughts.examples.azkarra.dependency Class Description TopologyProvider The default interface to supply a Kafka StreamsTopology
instance. -
Classes in io.streamthoughts.azkarra.api.streams used by io.streamthoughts.examples.azkarra.sse Class Description TopologyProvider The default interface to supply a Kafka StreamsTopology
instance. -
Classes in io.streamthoughts.azkarra.api.streams used by io.streamthoughts.examples.azkarra.topology Class Description TopologyProvider The default interface to supply a Kafka StreamsTopology
instance.