Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
-
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
- links to