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

Class MonitoringStreamsTask

java.lang.Object

java.lang.Thread

io.streamthoughts.azkarra.runtime.interceptors.monitoring.MonitoringStreamsTask

All Implemented Interfaces:

Runnable

public final class MonitoringStreamsTask
extends Thread

Task for reporting KafkaStreams state changes.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	MonitoringStreamsTask.Reportable<T>

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

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.

Method Summary

Modifier and Type	Method	Description
void	offer(KafkaStreamsMetadata state)
void	run()
void	shutdown()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Constructor Detail

MonitoringStreamsTask

public 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.

Method Detail

offer

public void offer(KafkaStreamsMetadata state)

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

shutdown

public void shutdown()