Package org.apache.kafka.streams.processor.internals

Interface ChangelogRegister

All Known Subinterfaces:

ChangelogReader

All Known Implementing Classes:

StoreChangelogReader

public interface ChangelogRegister

See StoreChangelogReader.

Method Summary

Modifier and Type	Method	Description
void	register(TopicPartition partition, ProcessorStateManager stateManager)	Register a state store for restoration.
void	unregister(Collection<TopicPartition> removedPartitions)	Unregisters and removes the passed in partitions from the set of changelogs

Method Detail

register

void register(TopicPartition partition,
              ProcessorStateManager stateManager)

Register a state store for restoration.

Parameters:

partition - the state store's changelog partition for restoring

stateManager - the state manager used for restoring (one per task)

unregister

void unregister(Collection<TopicPartition> removedPartitions)

Unregisters and removes the passed in partitions from the set of changelogs

Parameters:

removedPartitions - the set of partitions to remove