Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-10310 Kafka Raft Snapshot
  3. KAFKA-12956

Validate the snapshot id when the state machine freeze a snapshot

    XMLWordPrintableJSON

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.

      Attachments

        Activity

          People

            loboxu loboxu
            feyman Haoran Xuan
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated: