Record Class KafkaStreamsRuntimeState.ThreadState

java.lang.Object

java.lang.Record

io.micronaut.controlpanel.panels.kafka.KafkaStreamsRuntimeState.ThreadState

Record Components:

name - stream thread name

state - stream thread state

adminClientId - admin client identifier

consumerClientId - consumer client identifier

restoreConsumerClientId - restore consumer client identifier

producerClientIds - producer client identifiers

hasProducerClientIds - whether producer client identifiers are present

activeTasks - active task summary

standbyTasks - standby task summary

Enclosing class:

KafkaStreamsRuntimeState

public static record KafkaStreamsRuntimeState.ThreadState(String name, String state, String adminClientId, String consumerClientId, String restoreConsumerClientId, List<String> producerClientIds, boolean hasProducerClientIds, KafkaStreamsRuntimeState.TaskSummary activeTasks, KafkaStreamsRuntimeState.TaskSummary standbyTasks)
extends Record

Runtime state for one Kafka Streams thread.

Constructor Summary

Constructors

Constructor	Description
ThreadState(String name, String state, String adminClientId, String consumerClientId, String restoreConsumerClientId, List<String> producerClientIds, boolean hasProducerClientIds, KafkaStreamsRuntimeState.TaskSummary activeTasks, KafkaStreamsRuntimeState.TaskSummary standbyTasks)	Creates an instance of a ThreadState record class.

Method Summary

Modifier and Type	Method	Description
KafkaStreamsRuntimeState.TaskSummary	activeTasks()	Returns the value of the activeTasks record component.
String	adminClientId()	Returns the value of the adminClientId record component.
String	consumerClientId()	Returns the value of the consumerClientId record component.
final boolean	equals(Object o)	Indicates whether some other object is "equal to" this one.
final int	hashCode()	Returns a hash code value for this object.
boolean	hasProducerClientIds()	Returns the value of the hasProducerClientIds record component.
String	name()	Returns the value of the name record component.
List<String>	producerClientIds()	Returns the value of the producerClientIds record component.
String	restoreConsumerClientId()	Returns the value of the restoreConsumerClientId record component.
KafkaStreamsRuntimeState.TaskSummary	standbyTasks()	Returns the value of the standbyTasks record component.
String	state()	Returns the value of the state record component.
String	stateBadgeClass()
final String	toString()	Returns a string representation of this record class.

Methods inherited from class Object

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

Constructor Details

ThreadState

public ThreadState(String name,
 String state,
 String adminClientId,
 String consumerClientId,
 String restoreConsumerClientId,
 List<String> producerClientIds,
 boolean hasProducerClientIds,
 KafkaStreamsRuntimeState.TaskSummary activeTasks,
 KafkaStreamsRuntimeState.TaskSummary standbyTasks)

Creates an instance of a ThreadState record class.

Parameters:

name - the value for the name record component

state - the value for the state record component

adminClientId - the value for the adminClientId record component

consumerClientId - the value for the consumerClientId record component

restoreConsumerClientId - the value for the restoreConsumerClientId record component

producerClientIds - the value for the producerClientIds record component

hasProducerClientIds - the value for the hasProducerClientIds record component

activeTasks - the value for the activeTasks record component

standbyTasks - the value for the standbyTasks record component

Method Details

stateBadgeClass

public String stateBadgeClass()

Returns:

badge class for the stream thread state

toString

public final String toString()

Returns a string representation of this record class. The representation contains the name of the class, followed by the name and value of each of the record components.

Specified by:

toString in class Record

Returns:

a string representation of this object

hashCode

public final int hashCode()

Returns a hash code value for this object. The value is derived from the hash code of each of the record components.

Specified by:

hashCode in class Record

Returns:

a hash code value for this object

equals

public final boolean equals(Object o)

Indicates whether some other object is "equal to" this one. The objects are equal if the other object is of the same class and if all the record components are equal. Reference components are compared with Objects::equals(Object,Object); primitive components are compared with the compare method from their corresponding wrapper classes.

Specified by:

equals in class Record

Parameters:

o - the object with which to compare

Returns:

true if this object is the same as the o argument; false otherwise.

name

public String name()

Returns the value of the name record component.

Returns:

the value of the name record component

state

public String state()

Returns the value of the state record component.

Returns:

the value of the state record component

adminClientId

public String adminClientId()

Returns the value of the adminClientId record component.

Returns:

the value of the adminClientId record component

consumerClientId

public String consumerClientId()

Returns the value of the consumerClientId record component.

Returns:

the value of the consumerClientId record component

restoreConsumerClientId

public String restoreConsumerClientId()

Returns the value of the restoreConsumerClientId record component.

Returns:

the value of the restoreConsumerClientId record component

producerClientIds

public List<String> producerClientIds()

Returns the value of the producerClientIds record component.

Returns:

the value of the producerClientIds record component

hasProducerClientIds

public boolean hasProducerClientIds()

Returns the value of the hasProducerClientIds record component.

Returns:

the value of the hasProducerClientIds record component

activeTasks

public KafkaStreamsRuntimeState.TaskSummary activeTasks()

Returns the value of the activeTasks record component.

Returns:

the value of the activeTasks record component

standbyTasks

public KafkaStreamsRuntimeState.TaskSummary standbyTasks()

Returns the value of the standbyTasks record component.

Returns:

the value of the standbyTasks record component