Package org.apache.kafka.streams

Interface ThreadMetadata

public interface ThreadMetadata
Metadata of a stream thread.

  • Method Details

    • threadState

      String threadState()
      State of the stream thread
      Returns:
      the state

    • threadName

      String threadName()
      Name of the stream thread
      Returns:
      the name

    • activeTasks

      Set<TaskMetadata> activeTasks()
      Metadata of the active tasks assigned to the stream thread.
      Returns:
      metadata of the active tasks

    • standbyTasks

      Set<TaskMetadata> standbyTasks()
      Metadata of the standby tasks assigned to the stream thread.
      Returns:
      metadata of the standby tasks

    • consumerClientId

      String consumerClientId()
      Client ID of the Kafka consumer used by the stream thread.
      Returns:
      client ID of the Kafka consumer

    • restoreConsumerClientId

      String restoreConsumerClientId()
      Client ID of the restore Kafka consumer used by the stream thread
      Returns:
      client ID of the restore Kafka consumer

    • producerClientIds

      Set<String> producerClientIds()
      Client IDs of the Kafka producers used by the stream thread.
      Returns:
      client IDs of the Kafka producers

    • adminClientId

      String adminClientId()
      Client ID of the admin client used by the stream thread.
      Returns:
      client ID of the admin client

    • equals

      boolean equals(Object o)
      Compares the specified object with this ThreadMetadata. Returns true if and only if the specified object is also a ThreadMetadata and both threadName() are equal, threadState() are equal, activeTasks() contain the same elements, standbyTasks() contain the same elements, mainConsumerClientId() are equal, restoreConsumerClientId() are equal, producerClientIds() are equal, producerClientIds contain the same elements, and adminClientId() are equal.
      Overrides:
      equals in class Object
      Returns:
      true if this object is the same as the obj argument; false otherwise.

    • hashCode

      int hashCode()
      Returns the hash code value for this ThreadMetadata. The hash code of a list is defined to be the result of the following calculation: 
       
 Objects.hash(
             threadName,
             threadState,
             activeTasks,
             standbyTasks,
             mainConsumerClientId,
             restoreConsumerClientId,
             producerClientIds,
             adminClientId
             );
      Overrides:
      hashCode in class Object
      Returns:
      a hash code value for this object.