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

inSyncReplica in Partition needs some tweaks

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Blocker
    • Resolution: Fixed
    • Affects Version/s: 0.8.0
    • Fix Version/s: 0.8.0
    • Component/s: None
    • Labels:

      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

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

              Dates

              • Created:
                Updated:
                Resolved: