Uses of Interface
io.streamthoughts.azkarra.runtime.interceptors.monitoring.MonitoringReporter
-
Packages that use MonitoringReporter Package Description io.streamthoughts.azkarra.runtime.interceptors io.streamthoughts.azkarra.runtime.interceptors.monitoring -
-
Uses of MonitoringReporter in io.streamthoughts.azkarra.runtime.interceptors
Methods in io.streamthoughts.azkarra.runtime.interceptors that return types with arguments of type MonitoringReporter Modifier and Type Method Description Collection<MonitoringReporter>
MonitoringStreamsInterceptorConfig. getReporters()
Methods in io.streamthoughts.azkarra.runtime.interceptors with parameters of type MonitoringReporter Modifier and Type Method Description MonitoringStreamsInterceptor
MonitoringStreamsInterceptor. withMonitoringReporter(MonitoringReporter reporter)
Registers aMonitoringReporter
to this interceptor. -
Uses of MonitoringReporter in io.streamthoughts.azkarra.runtime.interceptors.monitoring
Classes in io.streamthoughts.azkarra.runtime.interceptors.monitoring that implement MonitoringReporter Modifier and Type Class Description class
KafkaMonitoringReporter
AMonitoringReporter
that send a serializedKafkaStreamsMetadata
into a Kafka topic.Constructor parameters in io.streamthoughts.azkarra.runtime.interceptors.monitoring with type arguments of type MonitoringReporter Constructor Description MonitoringStreamsTask(String applicationId, List<MonitoringReporter> reporters, MonitoringStreamsTask.Reportable<? extends KafkaStreamsMetadata> reportable, long intervalMs)
Creates a newMonitoringStreamsTask
instance.
-