Class StandbyTask

  • All Implemented Interfaces:
    Task

    public class StandbyTask
    extends AbstractTask
    implements Task
    A StandbyTask
    • Method Detail

      • isActive

        public boolean isActive()
        Specified by:
        isActive in interface Task
      • suspend

        public void suspend()
        Specified by:
        suspend in interface Task
      • resume

        public void resume()
        Specified by:
        resume in interface Task
      • prepareCommit

        public java.util.Map<org.apache.kafka.common.TopicPartition,​org.apache.kafka.clients.consumer.OffsetAndMetadata> prepareCommit()
        Flush stores before a commit
        Specified by:
        prepareCommit in interface Task
        Throws:
        StreamsException - fatal error, should close the thread
      • postCommit

        public void postCommit()
        Specified by:
        postCommit in interface Task
      • closeClean

        public void closeClean()
        Description copied from interface: Task
        Must be idempotent.
        Specified by:
        closeClean in interface Task
      • closeDirty

        public void closeDirty()
        Description copied from interface: Task
        Must be idempotent.
        Specified by:
        closeDirty in interface Task
      • closeCleanAndRecycleState

        public void closeCleanAndRecycleState()
        Description copied from interface: Task
        Attempt a clean close but do not close the underlying state
        Specified by:
        closeCleanAndRecycleState in interface Task
      • commitNeeded

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

        public java.util.Map<org.apache.kafka.common.TopicPartition,​java.lang.Long> changelogOffsets()
        Specified by:
        changelogOffsets in interface Task
        Returns:
        the offsets of all the changelog partitions associated with this task, indicating the current positions of the logged state stores of the task.
      • addRecords

        public void addRecords​(org.apache.kafka.common.TopicPartition partition,
                               java.lang.Iterable<org.apache.kafka.clients.consumer.ConsumerRecord<byte[],​byte[]>> records)
        Specified by:
        addRecords 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.
      • 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.
        Returns:
        A string representation of the Task instance.