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

Class KafkaMonitoringReporter

java.lang.Object

io.streamthoughts.azkarra.runtime.interceptors.monitoring.KafkaMonitoringReporter

All Implemented Interfaces:

Configurable, KafkaStreamsContainerAware, MonitoringReporter, AutoCloseable

public class KafkaMonitoringReporter
extends Object
implements MonitoringReporter, KafkaStreamsContainerAware

A MonitoringReporter that send a serialized KafkaStreamsMetadata into a Kafka topic.

Constructor Summary

Constructors

Constructor	Description
KafkaMonitoringReporter()

Method Summary

Modifier and Type	Method	Description
void	close()	Closes this MonitoringReporter.
void	configure(Conf configuration)	Configure this StreamsMetadataReporter.
void	report(KafkaStreamsMetadata metadata)	Called periodically by the monitoring tasks.
void	setKafkaStreamsContainer(KafkaStreamsContainer container)	Sets the KafkaStreamsContainer that this object runs in.
KafkaMonitoringReporter	withAdvertisedApplicationServer(String advertisedServer)
KafkaMonitoringReporter	withTopic(String topic)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KafkaMonitoringReporter

public KafkaMonitoringReporter()

Method Detail

report

public void report(KafkaStreamsMetadata metadata)

Called periodically by the monitoring tasks. This method can be called after MonitoringReporter.close() has been invoked if the stream instance is restarted.

Specified by:

report in interface MonitoringReporter

Parameters:

metadata - the KafkaStreamsMetadata change to report.

configure

public void configure(Conf configuration)

Configure this StreamsMetadataReporter.

Specified by:

configure in interface Configurable

Specified by:

configure in interface MonitoringReporter

Parameters:

configuration - the Conf instance used to configure this instance.

withTopic

public KafkaMonitoringReporter withTopic(String topic)

withAdvertisedApplicationServer

public KafkaMonitoringReporter withAdvertisedApplicationServer(String advertisedServer)

setKafkaStreamsContainer

public void setKafkaStreamsContainer(KafkaStreamsContainer container)

Sets the KafkaStreamsContainer that this object runs in.

Specified by:

setKafkaStreamsContainer in interface KafkaStreamsContainerAware

Parameters:

container - the KafkaStreamsContainer.

close

public void close()

Closes this MonitoringReporter. Called when a KafkaStreamsContainer is stopped.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface MonitoringReporter