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

Class KafkaStreamsMetadata

java.lang.Object

io.streamthoughts.azkarra.runtime.interceptors.monitoring.KafkaStreamsMetadata

public class KafkaStreamsMetadata
extends Object

Represents the runtime state of a single KafkaStreams instance.

Constructor Summary

Constructors

Constructor	Description
KafkaStreamsMetadata(TimestampedValue<State> state, Set<org.apache.kafka.streams.processor.ThreadMetadata> threads, ConsumerGroupOffsets offsets)	Creates a new KafkaStreamsMetadata instance.

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
int	hashCode()
ConsumerGroupOffsets	offsets()
State	state()
long	stateChangedTime()
Set<org.apache.kafka.streams.processor.ThreadMetadata>	threads()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

KafkaStreamsMetadata

public KafkaStreamsMetadata(TimestampedValue<State> state,
                            Set<org.apache.kafka.streams.processor.ThreadMetadata> threads,
                            ConsumerGroupOffsets offsets)

Creates a new KafkaStreamsMetadata instance.

Parameters:

state - the state of the instance.

threads - the set of ThreadMetadata of the instance.

offsets - the ConsumerGroupOffsets of the instance.

Method Detail

state

public State state()

stateChangedTime

public long stateChangedTime()

threads

public Set<org.apache.kafka.streams.processor.ThreadMetadata> threads()

offsets

public ConsumerGroupOffsets offsets()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object