Interface MonitoringReporter
-
- All Superinterfaces:
AutoCloseable
,Configurable
- All Known Implementing Classes:
KafkaMonitoringReporter
public interface MonitoringReporter extends AutoCloseable, Configurable
AMonitoringStreamsReporter
can be used to periodically report the state of a localKafkaStreams
instance. Implementations can implement the interfaceKafkaStreamsContainerAware
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description default void
close()
Closes thisMonitoringReporter
.default void
configure(Conf configuration)
Configure thisStreamsMetadataReporter
.void
report(KafkaStreamsMetadata metadata)
Called periodically by the monitoring tasks.
-
-
-
Method Detail
-
report
void report(KafkaStreamsMetadata metadata)
Called periodically by the monitoring tasks. This method can be called afterclose()
has been invoked if the stream instance is restarted.- Parameters:
metadata
- theKafkaStreamsMetadata
change to report.
-
configure
default void configure(Conf configuration)
Configure thisStreamsMetadataReporter
.- Specified by:
configure
in interfaceConfigurable
- Parameters:
configuration
- theConf
instance used to configure this instance.
-
close
default void close()
Closes thisMonitoringReporter
. Called when aKafkaStreamsContainer
is stopped.- Specified by:
close
in interfaceAutoCloseable
-
-