Ack. Will also add a comment. This slipped in `0.11` back port, too. I don't think it's an issue, because adding the partitions back within `task.reinitializeStateStoresForPartitions(restoringPartition);` is idempotent.
[ Full content available at: https://github.com/apache/kafka/pull/5657 ] This message was relayed via gitbox.apache.org for [email protected]
