+1 On 7/20/17 4:22 AM, Bill Bejeck wrote: > 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 >
signature.asc
Description: OpenPGP digital signature
