public class PostponeUrpReplicaMovementStrategy extends AbstractReplicaMovementStrategy
Constructor and Description |
---|
PostponeUrpReplicaMovementStrategy() |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
name()
Get the name of this strategy.
|
java.util.Comparator<ExecutionTask> |
taskComparator(org.apache.kafka.common.Cluster cluster)
Generate a comparator for replica movement task which incorporate the strategy to apply.
|
applyStrategy, chain
public java.util.Comparator<ExecutionTask> taskComparator(org.apache.kafka.common.Cluster cluster)
ReplicaMovementStrategy
cluster
- The current cluster state.public java.lang.String name()