[
https://issues.apache.org/jira/browse/KAFKA-15149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Grant updated KAFKA-15149:
---------------------------------
Description: 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.
> Fix not sending 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
> Priority: Major
>
> 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)
