Interface ChangelogReader
-
- All Known Implementing Classes:
StoreChangelogReader
public interface ChangelogReader
Performs bulk read operations from a set of partitions. Used to restoreStateStore
s 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()
-
-