Versions Compared

Key

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

...

Note that the broker will put ChangeReplicaRequest in a DelayedOperationPurgatory. The ChangeReplicaRequest can be completed when results for all partitions specified in the ChangeReplicaRequest are available. The result of a partition is determined using the following logic:

 

  • If source or destination disk fails, the result of this partition will be KafkaStorageException
  • If destination replica has caught up with source replica and has replaced source replica, the result of this partition has no error.

...