Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-800

inSyncReplica in Partition needs some tweaks

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Blocker
    • Resolution: Fixed
    • 0.8.0
    • 0.8.0
    • None

    Description

      1. isUnderReplicated method in Partition.scala needs to take the leaderIsrUpdateLock before reading the inSyncReplica structure. We suspect that this could cause the gauge to read stale values from the cache.

      2. toString api should take the leaderIsrUpdateLock to prevent anything from blowing up when it iterates the data structures

      Attachments

        1. KAFKA-800-v2.patch
          9 kB
          Sriram
        2. KAFKA-800.patch
          6 kB
          Sriram

        Activity

          People

            sriramsub Sriram
            sriramsub Sriram
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: