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