public class BrokerRemovalFuture extends Object
Constructor and Description |
---|
BrokerRemovalFuture(BrokerRemovalContext removalContext,
CompletableFuture<Void> initialFuture,
CompletableFuture<Void> chainedFutures) |
Modifier and Type | Method and Description |
---|---|
boolean |
cancel(String reason)
Attempt to cancel the broker removal operation future.
|
void |
execute(Duration duration)
Executes the broker removal
|
public BrokerRemovalFuture(BrokerRemovalContext removalContext, CompletableFuture<Void> initialFuture, CompletableFuture<Void> 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(String reason)
reason
- - the reason for cancelling the removal