Class ThreadMetadata
- java.lang.Object
-
- org.apache.kafka.streams.processor.ThreadMetadata
-
public class ThreadMetadata extends java.lang.Object
Represents the state of a single thread running within aKafkaStreams
application.
-
-
Constructor Summary
Constructors Constructor Description ThreadMetadata(java.lang.String threadName, java.lang.String threadState, java.lang.String mainConsumerClientId, java.lang.String restoreConsumerClientId, java.util.Set<java.lang.String> producerClientIds, java.lang.String adminClientId, java.util.Set<TaskMetadata> activeTasks, java.util.Set<TaskMetadata> standbyTasks)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.Set<TaskMetadata>
activeTasks()
java.lang.String
adminClientId()
java.lang.String
consumerClientId()
boolean
equals(java.lang.Object o)
int
hashCode()
java.util.Set<java.lang.String>
producerClientIds()
java.lang.String
restoreConsumerClientId()
java.util.Set<TaskMetadata>
standbyTasks()
java.lang.String
threadName()
java.lang.String
threadState()
java.lang.String
toString()
-
-
-
Constructor Detail
-
ThreadMetadata
public ThreadMetadata(java.lang.String threadName, java.lang.String threadState, java.lang.String mainConsumerClientId, java.lang.String restoreConsumerClientId, java.util.Set<java.lang.String> producerClientIds, java.lang.String adminClientId, java.util.Set<TaskMetadata> activeTasks, java.util.Set<TaskMetadata> standbyTasks)
-
-
Method Detail
-
threadState
public java.lang.String threadState()
-
threadName
public java.lang.String threadName()
-
activeTasks
public java.util.Set<TaskMetadata> activeTasks()
-
standbyTasks
public java.util.Set<TaskMetadata> standbyTasks()
-
consumerClientId
public java.lang.String consumerClientId()
-
restoreConsumerClientId
public java.lang.String restoreConsumerClientId()
-
producerClientIds
public java.util.Set<java.lang.String> producerClientIds()
-
adminClientId
public java.lang.String adminClientId()
-
equals
public boolean equals(java.lang.Object o)
- Overrides:
equals
in classjava.lang.Object
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-