Interface Task

    • Method Detail

      • initializeStateStores

        boolean initializeStateStores()
        Initialize the task and return true if the task is ready to run, i.e, it has not state stores
        Returns:
        true if this task has no state stores that may need restoring.
        Throws:
        java.lang.IllegalStateException - If store gets registered after initialized is already finished
        StreamsException - if the store's change log does not contain the partition
      • commitNeeded

        boolean commitNeeded()
      • initializeTopology

        void initializeTopology()
      • commit

        void commit()
      • suspend

        void suspend()
      • resume

        void resume()
      • closeSuspended

        void closeSuspended​(boolean clean,
                            boolean isZombie,
                            java.lang.RuntimeException e)
      • close

        void close​(boolean clean,
                   boolean isZombie)
      • getStore

        StateStore getStore​(java.lang.String name)
      • applicationId

        java.lang.String applicationId()
      • partitions

        java.util.Set<org.apache.kafka.common.TopicPartition> partitions()
      • changelogPartitions

        java.util.Collection<org.apache.kafka.common.TopicPartition> changelogPartitions()
        Returns:
        any changelog partitions associated with this task
      • hasStateStores

        boolean hasStateStores()
      • toString

        java.lang.String toString​(java.lang.String indent)