[ https://issues.apache.org/jira/browse/KAFKA-15149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Andrew Grant resolved KAFKA-15149. ---------------------------------- Resolution: Fixed > Fix not sending UMR and LISR RPCs in dual-write mode when there are new > partitions > ---------------------------------------------------------------------------------- > > Key: KAFKA-15149 > URL: https://issues.apache.org/jira/browse/KAFKA-15149 > Project: Kafka > Issue Type: Bug > Reporter: Andrew Grant > Assignee: Andrew Grant > Priority: Major > Fix For: 3.5.1 > > > In AK in {{KRaftMigrationZkWriter}} > [here|https://github.com/apache/kafka/blame/trunk/metadata/src/main/java/org/apache/kafka/metadata/migration/KRaftMigrationZkWriter.java#L294] > 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. -- This message was sent by Atlassian Jira (v8.20.10#820010)