Hi, After working on the PR for this KIP I discovered that we need to add and additional parameter (TopicPartition) to the StateRestoreListener interface methods.
The addition of the TopicPartition is required as the StateRestoreListener is for the entire application, thus all tasks with recovering state stores call the same listener instance. The TopicPartition is needed to disambiguate the progress of the state store recovery. For those that have voted before, please review the updated KIP <https://cwiki.apache.org/confluence/display/KAFKA/KIP-167:+Add+interface+for+the+state+store+restoration+process> and re-vote. Thanks, Bill
