Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-17165 Revisit LeaderEpochFileCache#writeToFileForTruncation
  3. KAFKA-17167

Moving the flush call inside the read lock when writing truncation

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Resolved
    • Minor
    • Resolution: Duplicate
    • None
    • None
    • None
    • None

    Description

      copy the discussion (https://github.com/apache/kafka/pull/16614#discussion_r1683340380) to here

      Consider the following sequence: we take a snapshot of the epoch entries here; a new epoch entry is added and is flushed to disk; the scheduler then writes the snapshot to disk. This can lead to the case where the leader epoch file doesn't contain all entries up to the recovery point.

      Attachments

        Activity

          People

            chiacyu Chia-Chuan Yu
            chia7712 Chia-Ping Tsai
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: