public class BrokerRemovalFuture extends Object
Constructor and Description |
---|
BrokerRemovalFuture(AtomicReference<Executor.ReservationHandle> reservationHandle,
CompletableFuture<Void> initialFuture,
CompletableFuture<Future<?>> chainedFutures) |
Modifier and Type | Method and Description |
---|---|
boolean |
cancel()
Attempt to cancel the broker removal operation future.
|
void |
execute(Duration duration)
Executes the broker removal
|
public BrokerRemovalFuture(AtomicReference<Executor.ReservationHandle> reservationHandle, CompletableFuture<Void> initialFuture, CompletableFuture<Future<?>> chainedFutures)
chainedFutures
- a #Future
consisting of the full broker removal operation -
the plan computation/shutdown operation and then the underlying reassignments executionpublic void execute(Duration duration) throws Throwable
Throwable
public boolean cancel()