Class AbstractTask

  • All Implemented Interfaces:
    Task
    Direct Known Subclasses:
    StandbyTask, StreamTask

    public abstract class AbstractTask
    extends java.lang.Object
    implements Task
    • Method Detail

      • id

        public TaskId id()
        Specified by:
        id in interface Task
      • applicationId

        public java.lang.String applicationId()
        Specified by:
        applicationId in interface Task
      • partitions

        public java.util.Set<org.apache.kafka.common.TopicPartition> partitions()
        Specified by:
        partitions in interface Task
      • toString

        public java.lang.String toString()
        Produces a string representation containing useful information about a Task. This is useful in debugging scenarios.
        Overrides:
        toString in class java.lang.Object
        Returns:
        A string representation of the StreamTask instance.
      • isEosEnabled

        public boolean isEosEnabled()
      • toString

        public java.lang.String toString​(java.lang.String indent)
        Produces a string representation containing useful information about a Task starting with the given indent. This is useful in debugging scenarios.
        Specified by:
        toString in interface Task
        Returns:
        A string representation of the Task instance.
      • activeTaskCheckpointableOffsets

        protected java.util.Map<org.apache.kafka.common.TopicPartition,​java.lang.Long> activeTaskCheckpointableOffsets()
      • updateOffsetLimits

        protected void updateOffsetLimits()
      • isClosed

        public boolean isClosed()
      • commitNeeded

        public boolean commitNeeded()
        Specified by:
        commitNeeded in interface Task
      • hasStateStores

        public boolean hasStateStores()
        Specified by:
        hasStateStores in interface Task
      • changelogPartitions

        public java.util.Collection<org.apache.kafka.common.TopicPartition> changelogPartitions()
        Specified by:
        changelogPartitions in interface Task
        Returns:
        any changelog partitions associated with this task