Package io.streamthoughts.azkarra.runtime.interceptors.monitoring

Interface Summary

Interface	Description
MonitoringReporter	A MonitoringStreamsReporter can be used to periodically report the state of a local KafkaStreams instance.
MonitoringStreamsTask.Reportable<T>

Class Summary

Class	Description
KafkaMonitoringReporter	A MonitoringReporter that send a serialized KafkaStreamsMetadata into a Kafka topic.
KafkaStreamsMetadata	Represents the runtime state of a single KafkaStreams instance.
MonitoringStreamsTask	Task for reporting KafkaStreams state changes.
StreamsExtensionBuilder