org.apache.kafka.streams.processor

Class ThreadMetadata

java.lang.Object

org.apache.kafka.streams.processor.ThreadMetadata

public class ThreadMetadata
extends Object

Represents the state of a single thread running within a KafkaStreams application.

Constructor Summary

Constructors

Constructor and Description
ThreadMetadata(String threadName, String threadState, String mainConsumerClientId, String restoreConsumerClientId, Set<String> producerClientIds, String adminClientId, Set<TaskMetadata> activeTasks, Set<TaskMetadata> standbyTasks)

Method Summary

Modifier and Type	Method and Description
Set<TaskMetadata>	activeTasks()
String	adminClientId()
String	consumerClientId()
boolean	equals(Object o)
int	hashCode()
Set<String>	producerClientIds()
String	restoreConsumerClientId()
Set<TaskMetadata>	standbyTasks()
String	threadName()
String	threadState()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ThreadMetadata

public ThreadMetadata(String threadName,
                      String threadState,
                      String mainConsumerClientId,
                      String restoreConsumerClientId,
                      Set<String> producerClientIds,
                      String adminClientId,
                      Set<TaskMetadata> activeTasks,
                      Set<TaskMetadata> standbyTasks)

Method Detail

threadState

public String threadState()

threadName

public String threadName()

activeTasks

public Set<TaskMetadata> activeTasks()

standbyTasks

public Set<TaskMetadata> standbyTasks()

consumerClientId

public String consumerClientId()

restoreConsumerClientId

public String restoreConsumerClientId()

producerClientIds

public Set<String> producerClientIds()

adminClientId

public String adminClientId()

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