Class StoreChangelogReader
- java.lang.Object
-
- org.apache.kafka.streams.processor.internals.StoreChangelogReader
-
- All Implemented Interfaces:
ChangelogReader
public class StoreChangelogReader extends java.lang.Object implements ChangelogReader
-
-
Constructor Summary
Constructors Constructor 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)
-
Method Summary
All Methods Instance Methods Concrete 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()
-
-
-
Constructor Detail
-
StoreChangelogReader
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)
-
-
Method Detail
-
register
public void register(StateRestorer restorer)
Description copied from interface:ChangelogReader
Register a state store and it's partition for later restoration.- Specified by:
register
in interfaceChangelogReader
- Parameters:
restorer
- the state restorer to register
-
restore
public java.util.Collection<org.apache.kafka.common.TopicPartition> restore(RestoringTasks active)
Description copied from interface:ChangelogReader
Restore all registered state stores by reading from their changelogs.- Specified by:
restore
in interfaceChangelogReader
- Returns:
- all topic partitions that have been restored
-
restoredOffsets
public java.util.Map<org.apache.kafka.common.TopicPartition,java.lang.Long> restoredOffsets()
- Specified by:
restoredOffsets
in interfaceChangelogReader
- Returns:
- the restored offsets for all persistent stores.
-
reset
public void reset()
- Specified by:
reset
in interfaceChangelogReader
-
-