public interface ChangelogReader
StateStore
s from their
change logsModifier and Type | Method and 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() |
void register(StateRestorer restorer)
restorer
- the state restorer to registerjava.util.Collection<org.apache.kafka.common.TopicPartition> restore(RestoringTasks active)
java.util.Map<org.apache.kafka.common.TopicPartition,java.lang.Long> restoredOffsets()
void reset()