[
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)
