Only if EOS is not turned on, we will still continue restoring but from the starting position, and hence calling `restorer.restoreStarted();`. In the other case, we call put the restorer back to `initialized` `task.reinitializeStateStoresForPartitions` which will then call `register` again to add the partition back to `needsInitializing.add(restorer.partition());` which will then be re-initialized in the next iteration. I think the logic is still correct.
[ Full content available at: https://github.com/apache/kafka/pull/5657 ] This message was relayed via gitbox.apache.org for [email protected]
