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

Fix not sending UMR and LISR RPCs in dual-write mode when there are new partitions

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • None
    • 3.5.1
    • None
    • None

    Description

      In AK in KRaftMigrationZkWriter here we keep references to both the new and changed partitions maps from the TopicsDelta instance. We mutate changedPartitions resulting in possibly mutating the TopicsDelta instance that is provided as input to the method. After making the ZK writes when we try and figure out the UMR and LISR requests we need to make in MigrationPropagator.sendRPCsToBrokersFromMetadataDelta the TopicsDelta has lost the changed partitions metadata. As a result, we might not send the expected UMR and LISR requests. 

      Attachments

        Issue Links

          Activity

            People

              andyg2 Andrew Grant
              andyg2 Andrew Grant
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: