Class ThreadMetadata


  • public class ThreadMetadata
    extends java.lang.Object
    Represents the state of a single thread running within a KafkaStreams application.
    • 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 class java.lang.Object
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class java.lang.Object
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object