@NotThreadSafe public class ExecutorInterBrokerReplicaMovement extends AbstractExecutorReplicaMovement
adminClient, adminUtils, executionTaskManager, LOG, recentlyRemovedBrokers, stopRequested, throttleHelper, uuid
Constructor and Description |
---|
ExecutorInterBrokerReplicaMovement(String executionUuid,
ExecutionTaskManager executionTaskManager,
Set<Integer> recentlyRemovedBrokers,
com.linkedin.kafka.cruisecontrol.executor.ReplicationThrottleHelper throttleHelper,
org.apache.kafka.clients.admin.ConfluentAdmin adminClient,
SbkAdminUtils adminUtils,
AtomicBoolean stopRequested,
Set<Integer> removedBrokers,
LoadMonitor loadMonitor,
org.apache.kafka.common.Cluster cluster,
org.apache.kafka.common.utils.Time time,
long retryWaitMs) |
Modifier and Type | Method and Description |
---|---|
void |
move(Executor.ExecutionTaskWaiter taskWaiter)
Moves the replicas according to the specific movement
|
maybeReexecuteTasks
public ExecutorInterBrokerReplicaMovement(String executionUuid, ExecutionTaskManager executionTaskManager, Set<Integer> recentlyRemovedBrokers, com.linkedin.kafka.cruisecontrol.executor.ReplicationThrottleHelper throttleHelper, org.apache.kafka.clients.admin.ConfluentAdmin adminClient, SbkAdminUtils adminUtils, AtomicBoolean stopRequested, Set<Integer> removedBrokers, LoadMonitor loadMonitor, org.apache.kafka.common.Cluster cluster, org.apache.kafka.common.utils.Time time, long retryWaitMs)
public void move(Executor.ExecutionTaskWaiter taskWaiter) throws InterruptedException
AbstractExecutorReplicaMovement
move
in class AbstractExecutorReplicaMovement
InterruptedException