kafka-streams-internals-RestoringTasks.adoc

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.