Details
-
Improvement
-
Status: Open
-
Major
-
Resolution: Unresolved
-
None
-
None
-
None
Description
TopicPartition is used as the key when computing the local changes in TopicsDelta. The topic id is included in the Map value return by localChanges. I think that the handling of this code and the corresponding code in ReplicaManager could be simplified if localChanges instead returned something like
{ deletes: Set[TopicIdPartition], leaders: Map[TopicIdPartition, PartitionRegistration], followers: Map[TopicIdPartition, PartitionRegistration] }