public class StoreChangelogReader extends java.lang.Object implements ChangelogReader
Constructor and Description |
---|
StoreChangelogReader(org.apache.kafka.clients.consumer.Consumer<byte[],byte[]> restoreConsumer,
java.time.Duration pollTime,
StateRestoreListener userStateRestoreListener,
org.apache.kafka.common.utils.LogContext logContext,
java.lang.String internalStreamCompacted) |
Modifier 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() |
public StoreChangelogReader(org.apache.kafka.clients.consumer.Consumer<byte[],byte[]> restoreConsumer, java.time.Duration pollTime, StateRestoreListener userStateRestoreListener, org.apache.kafka.common.utils.LogContext logContext, java.lang.String internalStreamCompacted)
public void register(StateRestorer restorer)
ChangelogReader
register
in interface ChangelogReader
restorer
- the state restorer to registerpublic java.util.Collection<org.apache.kafka.common.TopicPartition> restore(RestoringTasks active)
ChangelogReader
restore
in interface ChangelogReader
public java.util.Map<org.apache.kafka.common.TopicPartition,java.lang.Long> restoredOffsets()
restoredOffsets
in interface ChangelogReader
public void reset()
reset
in interface ChangelogReader