Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-13208

Use TopicIdPartition instead of TopicPartition when computing the topic delta

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Open
    • Major
    • Resolution: Unresolved
    • None
    • None
    • kraft, replication
    • 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] 
      }

      Attachments

        Activity

          People

            jagsancio Jose Armando Garcia Sancio
            jagsancio Jose Armando Garcia Sancio
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated: