Uses of Class
io.streamthoughts.azkarra.runtime.interceptors.monitoring.KafkaStreamsMetadata

Packages that use KafkaStreamsMetadata

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

Uses of KafkaStreamsMetadata in io.streamthoughts.azkarra.runtime.interceptors.monitoring

Methods in io.streamthoughts.azkarra.runtime.interceptors.monitoring with parameters of type KafkaStreamsMetadata

Modifier and Type	Method	Description
void	MonitoringStreamsTask.offer(KafkaStreamsMetadata state)
void	KafkaMonitoringReporter.report(KafkaStreamsMetadata metadata)	Called periodically by the monitoring tasks.
void	MonitoringReporter.report(KafkaStreamsMetadata metadata)	Called periodically by the monitoring tasks.

Constructor parameters in io.streamthoughts.azkarra.runtime.interceptors.monitoring with type arguments of type KafkaStreamsMetadata

Constructor	Description
MonitoringStreamsTask(String applicationId, List<MonitoringReporter> reporters, MonitoringStreamsTask.Reportable<? extends KafkaStreamsMetadata> reportable, long intervalMs)	Creates a new MonitoringStreamsTask instance.