Class TaskMetadata

java.lang.Object
org.apache.kafka.streams.processor.TaskMetadata

@Deprecated
public class TaskMetadata
extends Object
Deprecated.
since 3.0, use TaskMetadata instead.
Represents the state of a single task running within a KafkaStreams application.
  • Constructor Details

  • Method Details

    • taskId

      public String taskId()
      Deprecated.
      Returns:
      the basic task metadata such as subtopology and partition id
    • topicPartitions

      public Set<TopicPartition> topicPartitions()
      Deprecated.
    • committedOffsets

      public Map<TopicPartition,​Long> committedOffsets()
      Deprecated.
      This function will return a map of TopicPartitions and the highest committed offset seen so far
    • endOffsets

      public Map<TopicPartition,​Long> endOffsets()
      Deprecated.
      This function will return a map of TopicPartitions and the highest offset seen so far in the Topic
    • timeCurrentIdlingStarted

      public Optional<Long> timeCurrentIdlingStarted()
      Deprecated.
      This function will return the time task idling started, if the task is not currently idling it will return empty
    • equals

      public boolean equals​(Object o)
      Deprecated.
      Overrides:
      equals in class Object
    • hashCode

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

      public String toString()
      Deprecated.
      Overrides:
      toString in class Object