Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Following the previous plan, the snapshot state needs to save both assignedPartitions and unassignedInitialPartitons collections. Item of both collections are TopicPartition, but with different status. Therefore, we can use one collection to pull all them in.

With Adding a status , would make it would be easier to extend it for rules for the process of discovering more partitions laterthrough additional rules in the future.

Every Kafka partition in the Kafka snapshot state will have a "type" attribute indicating whether it is assigned or initial:

...