I just tried this, and `remove()` is actually incorrect here. If we remove it, we don't add it to `needsRestoring` at the end of the method, and thus return `true` instead of `false` in `StoreChangelogReader#completed()` -- ie, we don't reply the changelog into the store but claim, restore is finished after we wiped out the state.
However, the `put` is also not required, because `initialized` already contains the partition. Cf #5659 for `0.11.0` [ Full content available at: https://github.com/apache/kafka/pull/5657 ] This message was relayed via gitbox.apache.org for [email protected]
