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
      • inputPartitions

        public java.util.Set<org.apache.kafka.common.TopicPartition> inputPartitions()
        Specified by:
        inputPartitions 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
      • markChangelogAsCorrupted

        public void markChangelogAsCorrupted​(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)
        Specified by:
        markChangelogAsCorrupted in interface Task
      • isClosed

        public boolean isClosed()
        Specified by:
        isClosed in interface Task
      • revive

        public void revive()
        Description copied from interface: Task
        Revive a closed task to a created one; should never throw an exception
        Specified by:
        revive in interface Task
      • update

        public void update​(java.util.Set<org.apache.kafka.common.TopicPartition> topicPartitions,
                           java.util.Map<java.lang.String,​java.util.List<java.lang.String>> allTopologyNodesToSourceTopics)
        Description copied from interface: Task
        Updates input partitions and topology after rebalance
        Specified by:
        update in interface Task