jsancio commented on pull request #10593:
URL: https://github.com/apache/kafka/pull/10593#issuecomment-858925958


   > @jsancio Can you share more details about the possible concurrency 
scenario with createSnapshot ? BTW, will moving the validation to 
onSnapshotFrozen imply that before creating the snapshot, there's no 
validation? I think maybe we can keep the validation here and add some 
additional check before freeze() which makes the snapshot visible?
   
   @feyman2016, I think it is reasonable to do both. Validate when 
`createSnapshot` is called and validate again in `onSnapshotFrozen`. In both 
cases this validation should be optional. Validate if it is created through 
`RaftClient.createSnapshot`. Don't validate if `KafkaRaftClient` creates the 
snapshot internally because of a `FetchResponse` from the leader.
   
   I have been working on a PR related to this if you want to take a look: 
https://github.com/apache/kafka/pull/10786. It would be nice to get your PR 
merged before my PR.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Reply via email to