Details
-
Sub-task
-
Status: Open
-
Major
-
Resolution: Unresolved
-
None
-
None
-
None
-
None
Description
This is similar to KAFKA-10800, in this PR, optionally validate the snapshot id when `onSnapshotFrozen` is being called. The validation logic will be implemented in KAFKA-10800, and this Jira is supposed to directly call that logic.
Currently, the `onSnapshotFrozen` can be called by `KafkaRaftClient` and `SnapshotWriter`. Do not validate if it is called by `KafkaRaftClient` when it's downloading snapshot from leader, do validate if it is called by `SnapshotWriter` which implies generating a specific snapshot.