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)

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

Constructor	Description
MonitoringStreamsTask(String applicationId, String applicationServer, CloudEventsExtension customExtensions, MonitoringStreamsTask.Reportable<? extends KafkaStreamsMetadata> reportable, long intervalMs, org.apache.kafka.clients.producer.Producer<byte[],byte[]> producer, String topic)	Creates a new MonitoringStreamsTask instance.