Interface ChangelogReader

  • All Known Implementing Classes:
    StoreChangelogReader

    public interface ChangelogReader
    Performs bulk read operations from a set of partitions. Used to restore StateStores from their change logs
    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      void register​(StateRestorer restorer)
      Register a state store and it's partition for later restoration.
      void reset()  
      java.util.Collection<org.apache.kafka.common.TopicPartition> restore​(RestoringTasks active)
      Restore all registered state stores by reading from their changelogs.
      java.util.Map<org.apache.kafka.common.TopicPartition,​java.lang.Long> restoredOffsets()  
    • Method Detail

      • register

        void register​(StateRestorer restorer)
        Register a state store and it's partition for later restoration.
        Parameters:
        restorer - the state restorer to register
      • restore

        java.util.Collection<org.apache.kafka.common.TopicPartition> restore​(RestoringTasks active)
        Restore all registered state stores by reading from their changelogs.
        Returns:
        all topic partitions that have been restored
      • restoredOffsets

        java.util.Map<org.apache.kafka.common.TopicPartition,​java.lang.Long> restoredOffsets()
        Returns:
        the restored offsets for all persistent stores.
      • reset

        void reset()