RestoringTasks Contract

RestoringTasks is the abstraction of restoring task managers that can find the restoring StreamTask for a partition.

Table 1. RestoringTasks Contract
Method Description

restoringTaskFor

 
StreamTask restoringTaskFor(TopicPartition partition)

Finds the restoring StreamTask for a partition

Used exclusively when StoreChangelogReader is requested to restore
Note
 AssignedStreamsTasks is the default and only known implementation of the RestoringTasks Contract in Kafka Streams.

results matching ""

    No results matching ""