root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 3 Packages Projects Releases Wiki Activity
kafka/metadata
History
Igor Soarez 1f839b1cf8
KAFKA-16583: Handle PartitionChangeRecord without directory IDs (#16118) 
When PartitionRegistration#merge() reads a PartitionChangeRecord
from an older MetadataVersion, with a replica assignment change
and without #directories() set, it produces a direcotry assignment
of DirectoryId.UNASSIGNED. This is problematic because the MetadataVersion
may not yet support directory assignments, leading to a
UnwritableMetadataException in PartitionRegistration#toRecord.

Since the Controller always sets directories on PartitionChangeRecord
if the MetadataVersion supports it, via PartitionChangeBuilder,
there's no need for PartitionRegistration#merge() to populate
directories upon a replica assignment change.

Reviewers: Luke Chen <showuon@gmail.com>
 		2024-06-04 15:38:05 +01:00
..
src KAFKA-16583: Handle PartitionChangeRecord without directory IDs (#16118) 2024-06-04 15:38:05 +01:00
.gitignore
…